File tree Expand file tree Collapse file tree
src/test/java/io/weaviate/client6/v1/api/collections/batch Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2323import org .junit .Test ;
2424import org .slf4j .Logger ;
2525import org .slf4j .LoggerFactory ;
26- import org .slf4j .Marker ;
27- import org .slf4j .helpers .BasicMarker ;
28- import org .slf4j .helpers .BasicMarkerFactory ;
2926
3027import io .grpc .stub .StreamObserver ;
3128import io .weaviate .client6 .v1 .api .collections .CollectionHandleDefaults ;
@@ -104,6 +101,8 @@ private StreamObserver<Message> createStream(StreamObserver<Event> recv) {
104101 */
105102 @ Before
106103 public void startContext () throws InterruptedException {
104+ log .debug ("===================startContext==================" );
105+
107106 assert !Thread .currentThread ().isInterrupted () : "main thread interrupted" ;
108107 assert REQUEST_QUEUE .isEmpty () : "stream contains incoming message " + REQUEST_QUEUE .peek ();
109108
@@ -141,6 +140,8 @@ public void reset() throws Exception {
141140 eventThread .awaitTermination (10 , TimeUnit .SECONDS );
142141
143142 REQUEST_QUEUE .clear ();
143+
144+ log .debug ("==================================================" );
144145 }
145146
146147 private static final WeaviateProtoBatch .BatchStreamRequest .MessageCase START = WeaviateProtoBatch .BatchStreamRequest .MessageCase .START ;
You can’t perform that action at this time.
0 commit comments