Add simple ingest source for websockets - Githubissues

thatdot / quine

Quine • a streaming graph • https://quine.io • Discord: https://discord.gg/GMhd8TE4MR

https://quine.io

Other

301 stars 40 forks source link

Add simple ingest source for websockets #2

Closed emanb29 closed 2 years ago

emanb29 commented 2 years ago

Adds a simplified ingest source for websockets
Adds a recipe demonstrating websocket usage.
Also avoids a usage of the akka java DSL (scala DSL was almost certainly intended)

Constraints of the ingest source:

This source will send a series of text messages on first connecting to the websockets server. These messages are sent as fast as possible, and must be text-kinded (ie, not binary messages)
The source cannot nontrivial keepalive protocols
The source is implemented via akka streams' HTTP client and inherits the limitations thereof. Most notably, half-closed sessions are not supported.