Open Sidebar
Close Sidebar
Movie
0.1.0
MainMessage
Movie
AbstractActorContext
AbstractActorSystem
AbstractBehavior
ActorContext
State
ActorPath
ActorRef
ActorRefBase
ActorRegistry
ActorSystem
ActorSystemConfig
ActorSystemShuttingDownError
ActorUnavailableError
Address
Ask
Cancelled
Failure
LocalResponseRef
LocalResponseRefBase
Response
Success
TargetTerminated
Behaviors
Cluster
AllocationPlanner
AllocationPlanResult
AllocationSnapshot
BehaviorEntityProvider
BroadcastClusterRoutingPolicy
ClusterConfigurationError
ClusterDaemon
ClusterEvent
Kind
ClusterEventBus
ClusterExtension
ClusterRouterConfigurationError
ClusterRouterLimits
ClusterRouterListingObserver
ClusterRouterPool
ClusterRouterPoolBase
ClusterRouterRef
ClusterRouterRefBase
ClusterRouterRouteeLifecycle
ClusterRouterSettings
ClusterRouterStats
ClusterRouterStoppedError
ClusterRouterTelemetry
ClusterRouterUnavailableError
ClusterRoutingPolicy
ClusterRoutingPolicyFactory
ClusterRoutingStrategy
ClusterSettings
ClusterShardingConfigurationError
ClusterSingletonConfigurationError
ClusterSingletonRef
ClusterSnapshot
ClusterStats
ClusterTelemetry
ClusterTransport
EntityPartitioner
LeastLoadedAllocation
Member
MembershipCapacityError
MembershipCoordinator
MembershipState
MemberStatus
NoRebalance
NoShardOwnerError
PendingShardingDelivery
PersistentEntityProvider
PlanBootstrapCandidate
ProtocolMessage
Kind
RandomClusterRoutingPolicy
RateLimitedRebalance
ReachabilityState
RebalancePolicy
ReceptionistClusterEventListener
ReceptionistConfigurationError
ReceptionistDaemon
ReceptionistEnvelope
ReceptionistLimits
ReceptionistListing
ReceptionistListingBuilder
ReceptionistNodeState
ReceptionistStats
ReceptionistSubscription
ReceptionistSubscriptionBase
ReceptionistTelemetry
ReceptionistTransport
ReceptionistWatcher
RendezvousAllocation
RendezvousHashClusterRoutingPolicy
RoleAwareAllocation
RoundRobinClusterRoutingPolicy
ServiceKey
ServiceRef
ServiceRegistration
ShardAllocations
ShardAllocationStrategy
ShardAssignment
ShardedEntityProvider
ShardedEntityRef
ShardedEntityType
ShardHandoffInProgressError
ShardingClusterEventListener
ShardingControlAck
ShardingDaemon
ShardingEnvelope
Kind
ShardingMessage
ShardingMessageConverter
ShardingPlanState
ShardingSettings
ShardingStats
ShardingTelemetry
ShardKey
ShardLeaseUnavailableError
SingletonBackingIdentity
SingletonBackingKind
SingletonPartitioner
SingletonRegistration
SingletonRegistrationBase
SingletonSettings
SingletonStats
SingletonTelemetry
StableHashPartitioner
UniqueAddress
WeightedLeastLoadedAllocation
ClusterReceptionist
ClusterReceptionistExtension
ClusterRouters
ClusterRoutersExtension
ClusterSharding
ClusterShardingExtension
ClusterSingleton
ClusterSingletonExtension
ConcurrentDispatcher
Config
ConfigBuilder
ConfigError
ConfigValue
Database
DatabaseExtension
DeadLetter
DeadLetters
DeferredBehavior
Dispatcher
DispatcherRegistry
DrainAndStop
DurableAction
DurableEffect
DurableState
DurableStateBehavior
DurableStateExtension
Envelope
EventEffect
EventSourcedBehavior
EventSourcing
EventSourcingExtension
Execution
ExecutorExtension
ExecutorStopped
TaskFailure
TaskReply
TaskSuccess
Extension
ExtensionId
ExtensionRegistry
ExtensionStartError
Failed
Future
FutureAlreadyCompleted
FutureCancelled
FutureResult
FutureStatus
FutureSubscription
FutureTimeout
Mailbox
MailboxManager
MissingConfigError
OutboxEffect
ParallelDispatcher
PathRegistry
Persistence
AcknowledgeOutbox
AcquireShardLease
AppendEvents
Backend
BackendConfigurationError
BackendConnection
BackendRegistry
Factory
CircuitOpenError
ClaimOutbox
ConcurrentWriteError
ConnectionActor
ConnectionMessage
ConnectionPool
ConnectionRequest
ConnectionWorker
Stopped
DbArgs
DbExec
DbExecLastId
DbQueryString
DbQueryStrings
DeleteEventsTo
DeleteProjectionOffset
DeleteSnapshot
DeleteState
DurableStateBackend
EnsureEventStore
EnsureStateStore
EntityId
EntityProvider
Factory
EntityRegistry
EntityType
EventEnvelope
EventPage
EventStoreActor
EventStoreClient
EventStoreMessage
GetEntity
GetSchemaVersion
HealthSnapshot
HealthStatus
Id
InvalidMigrationHistoryError
JournalBackend
LoadEvents
LoadProjectionOffset
LoadSnapshot
LoadState
MaintenanceResult
MetricsSnapshot
MigrationChecksumMismatchError
OperationConflictError
OperationId
OutboxBackend
OutboxDispatcher
OutboxDispatchResult
OutboxEntry
PostgresBackend
PostgresBackendConnection
ProjectionBehindRetentionError
ProjectionOffsetRegressionError
ProjectionRunner
ProjectionRunResult
QueryBackend
QueryEvents
QueryStoreMessage
ReadinessSnapshot
RegistryMessage
ReleaseOutbox
ReleaseShardLease
RenewShardLease
ResiliencePolicy
RetentionBackend
RetentionResult
RetryableConnectionRequest
RunMaintenance
SaveProjectionOffset
SaveSnapshot
SaveState
SchemaBackend
SchemaMigration
SerializedEvent
ShardLeaseKey
ShardLeaseToken
SnapshotBackend
SnapshotRecord
SqlBackendConnection
SQLiteBackend
SQLiteBackendConnection
StaleShardOwnerError
StateRecord
StateStoreActor
StateStoreClient
StateStoreMessage
StoredEvent
StoredOutboxEntry
Telemetry
TypedConnectionRequest
UnknownBackendError
UnsafeRetentionError
UnsupportedSchemaVersionError
WriteResult
PersistentEntityExtension
PinnedDispatcher
Pipe
Failure
Message
Success
PoolExecutionContext
PostRestart
PostStart
PostStop
PreRestart
PreStart
PreStop
Promise
Queue
QueueNode
ReceiveMessageBehavior
Remote
AnyJsonPayload
AssociationConfirmation
AssociationHandshake
AssociationNegotiator
AssociationProtocolError
AssociationSettings
ClientTransportFactory
Connection
State
ConnectionStats
ControlDeduplicationCapacityError
ControlDeduplicationStats
ControlDeduplicator
ControlObservation
FrameCodec
Decoder
Encoder
FrameTooLargeError
HandshakeReady
HandshakeRejection
InboundConnection
InboundFrameBatchDecoder
InboundFrameReader
JsonPayload
JsonPayloadDecoder
MalformedFrameError
MalformedMessagePayloadError
MessageDeserializer
MessageRegistry
MessageWrapper
OutboundWriter
PendingAskRegistry
PendingControlBuffer
PoolStats
RawJsonPayload
RemoteActorRef
RemoteAskError
RemoteAskFailurePayload
RemoteAskResponseSenderRef
RemoteDeliveryError
RemoteExtension
RemoteFailedSystemPayload
RemotePeerIdentity
RemoteSystemFailureError
RemoteUnsupportedSystemMessageError
Remoting
SerializableJsonPayload
Server
ServerTransportWrapper
StripedConnectionPool
SystemMessageCodec
TypedDeserializer
TypedMessageWrapper
WireEnvelope
Kind
Restart
RestartStrategy
Resume
RootGuardian
RootGuardianMessage
SameBehavior
Scheduler
Stop
StoppedBehavior
Streams
StageState
Typed
BlueprintRuntime
BroadcastHub
SubscriberState
BufferOverflowError
Cancel
CollectSink
CompletionFlow
DeliveryControl
DropFlow
FilterFlow
Flow
Flows
FoldSink
ManualSource
ManualSourceControl
MapFlow
Materialization
MaterializationScope
MaterializedPipeline
MessageBase
NotUsed
OnComplete
OnError
OnNext
OnSubscribe
OverflowStrategy
PassThroughFlow
Produce
QueueOfferResult
QueueOfferStatus
Request
RunnableFoldPipeline
RunnableGraph
RunnablePipeline
Sink
Sinks
Source
Sources
StageChannel
StreamBuilder
StreamCancelledError
StreamClosedError
StreamCompleted
StreamElement
StreamEvent
StreamFailed
StreamRuntimeExtension
Subscribe
Subscription
SubscriptionCancel
SubscriptionRequest
TakeFlow
TapFlow
TestKitAssertionError
TestPublisherProbe
TestSinks
TestSources
TestSubscriberProbe
SupervisionConfig
SupervisionScope
SupervisionStrategy
SystemGuardian
SystemGuardianMessage
SystemMessage
Terminate
Terminated
TimerHandle
Unwatch
UserGuardian
UserGuardianMessage
Watch
WrongTypeConfigError
class
Movie::
Streams::
Typed::
StreamCompleted(T)
Movie::Streams::Typed::StreamCompleted(T)
Movie::Streams::Typed::StreamEvent(T)
Reference
Object
Defined in:
movie/streams/core.cr