15
15
16
16
package software .amazon .awssdk .core .async ;
17
17
18
+ import org .junit .Test ;
18
19
import org .reactivestreams .Publisher ;
20
+ import org .reactivestreams .Subscriber ;
19
21
import org .reactivestreams .tck .TestEnvironment ;
22
+ import software .amazon .awssdk .http .async .SimpleSubscriber ;
20
23
24
+ import java .io .BufferedWriter ;
21
25
import java .io .File ;
26
+ import java .io .FileWriter ;
22
27
import java .io .IOException ;
23
28
import java .nio .ByteBuffer ;
29
+ import java .nio .charset .StandardCharsets ;
30
+ import java .nio .file .FileSystem ;
31
+ import java .nio .file .Files ;
32
+ import java .nio .file .Paths ;
33
+
34
+ import static org .assertj .core .api .Assertions .assertThat ;
35
+ import static org .mockito .Matchers .any ;
36
+ import static org .mockito .Mockito .*;
24
37
25
38
public class FileAsyncRequestPublisherTckTest extends org .reactivestreams .tck .PublisherVerification <ByteBuffer > {
26
39
@@ -29,6 +42,15 @@ public class FileAsyncRequestPublisherTckTest extends org.reactivestreams.tck.Pu
29
42
30
43
public FileAsyncRequestPublisherTckTest () throws IOException {
31
44
super (new TestEnvironment ());
45
+
46
+ BufferedWriter writer = new BufferedWriter (new FileWriter (example ));
47
+ writer .write ("Hello world\n " );
48
+ writer .write ("Hello world\n " );
49
+ writer .write ("Hello world\n " );
50
+ writer .write ("Hello world\n " );
51
+ writer .write ("Hello world\n " );
52
+ writer .flush ();
53
+ writer .close ();
32
54
}
33
55
34
56
@ Override
0 commit comments