1818import feign .Feign ;
1919import feign .RequestLine ;
2020import feign .Response ;
21- import feign .jackson .JacksonIteratorDecoder ;
2221import java .io .BufferedReader ;
2322import java .io .Closeable ;
2423import java .io .IOException ;
@@ -61,7 +60,7 @@ class Car {
6160 + "]\n " ;
6261
6362 @ Test
64- public void simpleStreamTest () throws IOException , InterruptedException {
63+ public void simpleStreamTest () {
6564 MockWebServer server = new MockWebServer ();
6665 server .enqueue (new MockResponse ().setBody ("foo\n bar" ));
6766
@@ -76,23 +75,6 @@ public void simpleStreamTest() throws IOException, InterruptedException {
7675 }
7776 }
7877
79- @ Test
80- public void simpleJsonStreamTest () throws IOException , InterruptedException {
81- MockWebServer server = new MockWebServer ();
82- server .enqueue (new MockResponse ().setBody (carsJson ));
83-
84- ObjectMapper mapper = new ObjectMapper ();
85-
86- StreamInterface api = Feign .builder ()
87- .decoder (StreamDecoder .create (JacksonIteratorDecoder .create ()))
88- .doNotCloseAfterDecode ()
89- .target (StreamInterface .class , server .url ("/" ).toString ());
90-
91- try (Stream <StreamInterface .Car > stream = api .getCars ()) {
92- assertThat (stream .collect (Collectors .toList ())).hasSize (2 );
93- }
94- }
95-
9678 @ Test
9779 public void shouldCloseIteratorWhenStreamClosed () throws IOException {
9880 Response response = Response .builder ()
@@ -119,7 +101,7 @@ static class TestCloseableIterator implements Iterator<String>, Closeable {
119101 boolean closed ;
120102
121103 @ Override
122- public void close () throws IOException {
104+ public void close () {
123105 this .closed = true ;
124106 }
125107
0 commit comments