|
Thank you for the support! Here is the stacktrace:
Daemon Thread [my-thread] (Suspended)
|
... user code
|
CallbackCompletableObserver.onComplete() line: 53
|
CompletableFromPublisher$FromPublisherSubscriber<T>.onComplete() line: 68
|
ObservableToPublisher$1.onComplete() line: 78
|
SingleResultCallbackSubscription<TResult>(AbstractSubscription<TResult>).onComplete() line: 145
|
SingleResultCallbackSubscription<TResult>(AbstractSubscription<TResult>).processResultsQueue() line: 211
|
SingleResultCallbackSubscription<TResult>(AbstractSubscription<TResult>).tryProcessResultsQueue() line: 159
|
SingleResultCallbackSubscription$1.onResult(TResult, Throwable) line: 48
|
MongoCollectionImpl$4.onResult(BulkWriteResult, Throwable) line: 646
|
MongoCollectionImpl$4.onResult(Object, Throwable) line: 640
|
MongoCollectionImpl$9.onResult(BulkWriteResult, Throwable) line: 1043
|
MongoCollectionImpl$9.onResult(Object, Throwable) line: 1027
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
OperationExecutorImpl$2$1.onResult(T, Throwable) line: 117
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
OperationHelper$ConnectionReleasingWrappedCallback<T>.onResult(T, Throwable) line: 384
|
MixedBulkWriteOperation.addBatchResult(BsonDocument, AsyncWriteBinding, AsyncConnection, BulkWriteBatch, boolean, ConnectionReleasingWrappedCallback<BulkWriteResult>) line: 506
|
MixedBulkWriteOperation.access$1500(MixedBulkWriteOperation, BsonDocument, AsyncWriteBinding, AsyncConnection, BulkWriteBatch, boolean, OperationHelper$ConnectionReleasingWrappedCallback) line: 70
|
MixedBulkWriteOperation$6.onResult(BsonDocument, Throwable) line: 486
|
MixedBulkWriteOperation$6.onResult(Object, Throwable) line: 458
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
DefaultServer$DefaultServerProtocolExecutor$2.onResult(T, Throwable) line: 227
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
CommandProtocolImpl$1.onResult(T, Throwable) line: 85
|
DefaultConnectionPool$PooledConnection$1.onResult(T, Throwable) line: 461
|
UsageTrackingInternalConnection$2.onResult(T, Throwable) line: 111
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
InternalStreamConnection$2$1.onResult(ResponseBuffers, Throwable) line: 395
|
InternalStreamConnection$2$1.onResult(Object, Throwable) line: 372
|
InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(ByteBuf, Throwable) line: 667
|
InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(Object, Throwable) line: 634
|
InternalStreamConnection$5.completed(ByteBuf) line: 510
|
InternalStreamConnection$5.completed(Object) line: 507
|
AsynchronousChannelStream$BasicCompletionHandler.completed(Integer, Void) line: 220
|
AsynchronousChannelStream$BasicCompletionHandler.completed(Object, Object) line: 203
|
Invoker.invokeUnchecked(CompletionHandler<V,? super A>, A, V, Throwable) line: 127
|
Invoker.invokeDirect(GroupAndInvokeCount, CompletionHandler<V,? super A>, A, V, Throwable) line: 158
|
UnixAsynchronousSocketChannelImpl.implRead(boolean, ByteBuffer, ByteBuffer[], long, TimeUnit, A, CompletionHandler<V,? super A>) line: 560
|
UnixAsynchronousSocketChannelImpl(AsynchronousSocketChannelImpl).read(boolean, ByteBuffer, ByteBuffer[], long, TimeUnit, A, CompletionHandler<V,? super A>) line: 277
|
UnixAsynchronousSocketChannelImpl(AsynchronousSocketChannelImpl).read(ByteBuffer, long, TimeUnit, A, CompletionHandler<Integer,? super A>) line: 298
|
AsynchronousSocketChannelStream$AsynchronousSocketChannelAdapter.read(ByteBuffer, long, TimeUnit, A, CompletionHandler<Integer,? super A>) line: 137
|
AsynchronousSocketChannelStream(AsynchronousChannelStream).readAsync(int, AsyncCompletionHandler<ByteBuf>) line: 105
|
InternalStreamConnection.readAsync(int, SingleResultCallback<ByteBuf>) line: 507
|
InternalStreamConnection.access$1000(InternalStreamConnection, int, SingleResultCallback) line: 74
|
InternalStreamConnection$MessageHeaderCallback.onResult(ByteBuf, Throwable) line: 624
|
InternalStreamConnection$MessageHeaderCallback.onResult(Object, Throwable) line: 609
|
InternalStreamConnection$5.completed(ByteBuf) line: 510
|
InternalStreamConnection$5.completed(Object) line: 507
|
AsynchronousChannelStream$BasicCompletionHandler.completed(Integer, Void) line: 220
|
AsynchronousChannelStream$BasicCompletionHandler.completed(Object, Object) line: 203
|
Invoker.invokeUnchecked(CompletionHandler<V,? super A>, A, V, Throwable) line: 127
|
UnixAsynchronousSocketChannelImpl.finishRead(boolean) line: 437
|
UnixAsynchronousSocketChannelImpl.finish(boolean, boolean, boolean) line: 191
|
UnixAsynchronousSocketChannelImpl.onEvent(int, boolean) line: 213
|
EPollPort$EventHandlerTask.run() line: 306
|
AsynchronousChannelGroupImpl$1.run() line: 112
|
ThreadPoolExecutor.runWorker(ThreadPoolExecutor$Worker) line: 1128
|
ThreadPoolExecutor$Worker.run() line: 628
|
Thread.run() line: 834
|
And with stepping over this gets to to the point in my original post:
Daemon Thread [my-thread] (Suspended)
|
SingleResultCallbackSubscription<TResult>(AbstractSubscription<TResult>).tryProcessResultsQueue() line: 161
|
SingleResultCallbackSubscription$1.onResult(TResult, Throwable) line: 48
|
MongoCollectionImpl$4.onResult(BulkWriteResult, Throwable) line: 646
|
MongoCollectionImpl$4.onResult(Object, Throwable) line: 640
|
MongoCollectionImpl$9.onResult(BulkWriteResult, Throwable) line: 1043
|
MongoCollectionImpl$9.onResult(Object, Throwable) line: 1027
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
OperationExecutorImpl$2$1.onResult(T, Throwable) line: 117
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
OperationHelper$ConnectionReleasingWrappedCallback<T>.onResult(T, Throwable) line: 384
|
MixedBulkWriteOperation.addBatchResult(BsonDocument, AsyncWriteBinding, AsyncConnection, BulkWriteBatch, boolean, ConnectionReleasingWrappedCallback<BulkWriteResult>) line: 506
|
MixedBulkWriteOperation.access$1500(MixedBulkWriteOperation, BsonDocument, AsyncWriteBinding, AsyncConnection, BulkWriteBatch, boolean, OperationHelper$ConnectionReleasingWrappedCallback) line: 70
|
MixedBulkWriteOperation$6.onResult(BsonDocument, Throwable) line: 486
|
MixedBulkWriteOperation$6.onResult(Object, Throwable) line: 458
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
DefaultServer$DefaultServerProtocolExecutor$2.onResult(T, Throwable) line: 227
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
CommandProtocolImpl$1.onResult(T, Throwable) line: 85
|
DefaultConnectionPool$PooledConnection$1.onResult(T, Throwable) line: 461
|
UsageTrackingInternalConnection$2.onResult(T, Throwable) line: 111
|
ErrorHandlingResultCallback<T>.onResult(T, Throwable) line: 49
|
InternalStreamConnection$2$1.onResult(ResponseBuffers, Throwable) line: 395
|
InternalStreamConnection$2$1.onResult(Object, Throwable) line: 372
|
InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(ByteBuf, Throwable) line: 667
|
InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(Object, Throwable) line: 634
|
InternalStreamConnection$5.completed(ByteBuf) line: 510
|
InternalStreamConnection$5.completed(Object) line: 507
|
AsynchronousChannelStream$BasicCompletionHandler.completed(Integer, Void) line: 220
|
AsynchronousChannelStream$BasicCompletionHandler.completed(Object, Object) line: 203
|
Invoker.invokeUnchecked(CompletionHandler<V,? super A>, A, V, Throwable) line: 127
|
Invoker.invokeDirect(GroupAndInvokeCount, CompletionHandler<V,? super A>, A, V, Throwable) line: 158
|
UnixAsynchronousSocketChannelImpl.implRead(boolean, ByteBuffer, ByteBuffer[], long, TimeUnit, A, CompletionHandler<V,? super A>) line: 560
|
UnixAsynchronousSocketChannelImpl(AsynchronousSocketChannelImpl).read(boolean, ByteBuffer, ByteBuffer[], long, TimeUnit, A, CompletionHandler<V,? super A>) line: 277
|
UnixAsynchronousSocketChannelImpl(AsynchronousSocketChannelImpl).read(ByteBuffer, long, TimeUnit, A, CompletionHandler<Integer,? super A>) line: 298
|
AsynchronousSocketChannelStream$AsynchronousSocketChannelAdapter.read(ByteBuffer, long, TimeUnit, A, CompletionHandler<Integer,? super A>) line: 137
|
AsynchronousSocketChannelStream(AsynchronousChannelStream).readAsync(int, AsyncCompletionHandler<ByteBuf>) line: 105
|
InternalStreamConnection.readAsync(int, SingleResultCallback<ByteBuf>) line: 507
|
InternalStreamConnection.access$1000(InternalStreamConnection, int, SingleResultCallback) line: 74
|
InternalStreamConnection$MessageHeaderCallback.onResult(ByteBuf, Throwable) line: 624
|
InternalStreamConnection$MessageHeaderCallback.onResult(Object, Throwable) line: 609
|
InternalStreamConnection$5.completed(ByteBuf) line: 510
|
InternalStreamConnection$5.completed(Object) line: 507
|
AsynchronousChannelStream$BasicCompletionHandler.completed(Integer, Void) line: 220
|
AsynchronousChannelStream$BasicCompletionHandler.completed(Object, Object) line: 203
|
Invoker.invokeUnchecked(CompletionHandler<V,? super A>, A, V, Throwable) line: 127
|
UnixAsynchronousSocketChannelImpl.finishRead(boolean) line: 437
|
UnixAsynchronousSocketChannelImpl.finish(boolean, boolean, boolean) line: 191
|
UnixAsynchronousSocketChannelImpl.onEvent(int, boolean) line: 213
|
EPollPort$EventHandlerTask.run() line: 306
|
AsynchronousChannelGroupImpl$1.run() line: 112
|
ThreadPoolExecutor.runWorker(ThreadPoolExecutor$Worker) line: 1128
|
ThreadPoolExecutor$Worker.run() line: 628
|
Thread.run() line: 834
|
I don't know if that will work for you. Please tell me if you need anything more. As I said, if this is not enough and a reproduction is needed, this will take longer. However, debugging is easy for me so if you want, I could tell you the values of variables, etc, if that would help you figure it out.
|