avokka.velocystream
Members list
Type members
Classlikes
chunk of message
chunk of message
Value parameters
- data
-
chunk payload
- header
-
header to reassemble message
Attributes
- Companion
- object
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass Objecttrait Matchableclass AnyShow all
Attributes
- Companion
- class
- Supertypes
- Self type
-
VStreamChunk.type
Attributes
- Supertypes
-
class Objecttrait Matchableclass Any
- Known subtypes
-
object VStreamChunk.type
- Self type
-
VStreamChunk.type
header of chunk
header of chunk
Value parameters
- id
-
unique message identifier
- length
-
total size of message in bytes
- x
-
chunkx
Attributes
- Companion
- object
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass Objecttrait Matchableclass AnyShow all
Attributes
- Companion
- class
- Supertypes
-
trait Producttrait Mirrorclass Objecttrait Matchableclass Any
- Self type
-
VStreamChunkHeader.type
ChunkX chunk/isFirstChunk (upper 31bits/lowest bit)
ChunkX chunk/isFirstChunk (upper 31bits/lowest bit)
"chunk" and "isFirstChunk" are combined into an unsigned 32bit value
chunk = chunkX >> 1 isFirstChunk = chunkX & 0x1
For the first chunk of a message, the low bit of the second uint32_t is set, for all subsequent ones it is reset. In the first chunk of a message, the number "chunk" is the total number of chunks in the message, in all subsequent chunks, the number "chunk" is the current number of this chunk.
Attributes
- Companion
- object
- Supertypes
-
class AnyValtrait Matchableclass Any
Attributes
- Companion
- class
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
VStreamChunkX.type
Velocystream client actor
Velocystream client actor
Attributes
- Companion
- object
- Supertypes
-
trait ActorLoggingtrait Stashtrait RequiresMessageQueue[DequeBasedMessageQueueSemantics]trait UnrestrictedStashtrait Actorclass Objecttrait Matchableclass AnyShow all
Attributes
- Companion
- class
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
VStreamClient.type
Attributes
- Companion
- object
- Supertypes
-
class Objecttrait Matchableclass Any
- Known subtypes
-
class ArangoConfiguration
Attributes
- Companion
- trait
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
VStreamConfiguration.type
Velocystream TCP connection
Velocystream TCP connection
Value parameters
- begin
-
first messages to send (authorization for example)
- conf
-
configuration
Attributes
- Companion
- object
- Supertypes
-
trait ActorLoggingtrait Actorclass Objecttrait Matchableclass Any
Attributes
- Companion
- class
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
VStreamConnection.type
velocystream message in or out
velocystream message in or out
Value parameters
- data
-
data bytes
- id
-
unique identifier
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass Objecttrait Matchableclass AnyShow all
actor waiting for chunks from server and reply with complete message
actor waiting for chunks from server and reply with complete message
Value parameters
- id
-
message id
- replyTo
-
actor which sent the request
Attributes
- Companion
- object
- Supertypes
-
trait ActorLoggingtrait Actorclass Objecttrait Matchableclass Any
Attributes
- Companion
- class
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
VStreamMessageActor.type
velocystream connection reader handles Tcp.Received events, accumulates bitvector and tries to decodes chunks, then send those chunks to message actor children
velocystream connection reader handles Tcp.Received events, accumulates bitvector and tries to decodes chunks, then send those chunks to message actor children
Attributes
- Companion
- object
- Supertypes
-
trait ActorLoggingtrait Actorclass Objecttrait Matchableclass Any
Attributes
- Companion
- class
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
VStreamReader.type