Uses of Class
services.moleculer.stream.PacketStream
Packages that use PacketStream
-
Uses of PacketStream in services.moleculer.context
Fields in services.moleculer.context declared as PacketStreamMethods in services.moleculer.context that return PacketStreamModifier and TypeMethodDescriptionContextSource.createStream()Creates a stream what is suitable for transferring large files (or other "unlimited" media content) between Moleculer Nodes.Methods in services.moleculer.context with parameters of type PacketStreamModifier and TypeMethodDescriptionprotected voidContext.broadcast(String name, io.datatree.Tree payload, Groups groups, PacketStream stream, CallOptions.Options opts, boolean local) protected voidContextSource.broadcast(String name, io.datatree.Tree payload, Groups groups, PacketStream stream, CallOptions.Options opts, boolean local) voidContextSource.broadcast(String name, PacketStream stream) Sends an event to ALL listeners from ALL event groups, who are listening this event.voidContextSource.broadcast(String name, PacketStream stream, Groups groups) Sends an event to ALL listeners from ALL event groups, who are listening this event.protected io.datatree.PromiseContext.call(String name, io.datatree.Tree params, CallOptions.Options opts, PacketStream stream) Calls an action (local or remote).protected io.datatree.PromiseContextSource.call(String name, io.datatree.Tree params, CallOptions.Options opts, PacketStream stream) io.datatree.PromiseContextSource.call(String name, PacketStream stream) Calls an action (local or remote).io.datatree.PromiseContextSource.call(String name, PacketStream stream, CallOptions.Options opts) Calls an action (local or remote).protected voidContext.emit(String name, io.datatree.Tree payload, Groups groups, PacketStream stream, CallOptions.Options opts) protected voidContextSource.emit(String name, io.datatree.Tree payload, Groups groups, PacketStream stream, CallOptions.Options opts) voidContextSource.emit(String name, PacketStream stream) Emits an event to ONE listener from ALL event groups, who are listening this event.voidContextSource.emit(String name, PacketStream stream, Groups groups) Emits an event to ONE listener from ALL event groups, who are listening this event.Constructors in services.moleculer.context with parameters of type PacketStreamModifierConstructorDescriptionContext(ServiceInvoker serviceInvoker, Eventbus eventbus, UidGenerator uidGenerator, String id, String name, io.datatree.Tree params, int level, String parentID, String requestID, PacketStream stream, CallOptions.Options opts, String nodeID) -
Uses of PacketStream in services.moleculer.stream
Fields in services.moleculer.stream declared as PacketStreamModifier and TypeFieldDescriptionprotected final PacketStreamIncomingStream.streamInternal stream with listeners.Methods in services.moleculer.stream that return PacketStream -
Uses of PacketStream in services.moleculer.util
Fields in services.moleculer.util declared as PacketStream