Skip to content

Commit

Permalink
[websocket] Invoke send listeners
Browse files Browse the repository at this point in the history
  • Loading branch information
Flowdalic committed Jan 18, 2024
1 parent b117d8c commit 8133505
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -271,6 +271,7 @@ protected void notifyAboutNewOutgoingElements() {
asyncButOrderedOutgoingElementsQueue.performAsyncButOrdered(outgoingElementsQueue, () -> {
for (TopLevelStreamElement topLevelStreamElement; (topLevelStreamElement = outgoingElementsQueue.poll()) != null;) {
websocket.send(topLevelStreamElement);
connectionInternal.fireFirstLevelElementSendListeners(topLevelStreamElement);
}
});
}
Expand Down

0 comments on commit 8133505

Please sign in to comment.