class CommandConnector extends AnyRef
- Source
- CommandConnector.scala
- Alphabetic
- By Inheritance
- CommandConnector
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new CommandConnector(messages: Source[(Message, CacheSnapshot), NotUsed], requests: requests.Requests, parallelism: Int)
- messages
A source of messages and their cache. All the messages that will be considered for commands.
- requests
A request helper to send errors and pass to command messages
- parallelism
How many command messages are constructed at once.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def bulkRunNamed(commands: NamedCommand[_]*): Seq[(NamedCommand[_], CommandRegistration[_])]
Starts many named commands at the same time.
Starts many named commands at the same time. They must all have a materialized value of NotUsed.
- commands
The commands to run.
- returns
The commands together with their completions.
- def bulkRunNamedWithHelp(helpCommand: HelpCommand, commands: NamedDescribedCommand[_]*): Seq[(NamedDescribedCommand[_], CommandRegistration[_])]
Starts many named commands at the same time and registers them with the help command.
Starts many named commands at the same time and registers them with the help command. They must all have a materialized value of NotUsed.
- commands
The commands to run.
- returns
The commands together with their completions.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def newCommand[A, Mat](prefix: PrefixParser, command: ComplexCommand[A, Mat]): RunnableGraph[CommandRegistration[Mat]]
Creates a RunnableGraph for a command.
Creates a RunnableGraph for a command.
- A
The type of arguments this command uses.
- Mat
The materialized result of running the command graph.
- prefix
The prefix to parse before the command.
- command
The command to use when creating the graph.
- returns
A runnable graph representing the execution of this command. Errors are sent as messages to the channel the command was used from.
- See also
- def newCommandWithErrors[A, Mat](prefix: PrefixParser, command: ComplexCommand[A, Mat]): Source[CommandError, CommandRegistration[Mat]]
Composes a command's flow and the source of messages to consider for commands.
Composes a command's flow and the source of messages to consider for commands.
- A
The type of arguments this command uses.
- Mat
The materialized result of running the command graph.
- prefix
A prefix parser to use for this command. In most cases create it by calling prefix.
- command
A command the compose with.
- returns
A source of command errors that can be used however you want.
- def newNamedCommand[A, Mat](command: NamedComplexCommand[A, Mat]): RunnableGraph[CommandRegistration[Mat]]
Creates a RunnableGraph for a named command.
Creates a RunnableGraph for a named command.
- A
The type of arguments this command uses.
- Mat
The materialized result of running the command graph.
- command
The named command to use when creating the graph.
- returns
A runnable graph representing the execution of this command. Errors are sent as messages to the channel the command was used from.
- See also
- def newNamedCommandWithErrors[A, Mat](command: NamedComplexCommand[A, Mat]): Source[CommandError, CommandRegistration[Mat]]
Composes a named command's flow and the source of messages to consider for commands.
Composes a named command's flow and the source of messages to consider for commands.
- A
The type of arguments this command uses.
- Mat
The materialized result of running the command graph.
- command
A named command the compose with.
- returns
A source of command errors that can be used however you want.
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def runNewCommand[A, Mat](prefix: PrefixParser, command: ComplexCommand[A, Mat]): CommandRegistration[Mat]
Starts a command execution.
Starts a command execution.
- A
The type of arguments this command uses.
- Mat
The materialized result of running the command graph.
- prefix
The prefix to use for the command.
- command
The command to run.
- returns
The materialized result of running the command, in addition to a future signaling when the command is done running.
- def runNewNamedCommand[A, Mat](command: NamedComplexCommand[A, Mat]): CommandRegistration[Mat]
Starts a named command execution.
Starts a named command execution.
- A
The type of arguments this command uses.
- Mat
The materialized result of running the command graph.
- command
The named command to run.
- returns
The materialized result of running the command, in addition to a future signaling when the command is done running.
- def runNewNamedCommandWithHelp[A, Mat](command: NamedDescribedComplexCommand[A, Mat], helpCommand: HelpCommand): CommandRegistration[Mat]
Starts a named command execution and registers it with the help command.
Starts a named command execution and registers it with the help command.
- A
The type of arguments this command uses.
- Mat
The materialized result of running the command graph.
- command
The named command to run.
- helpCommand
The help command to register the commandf with.
- returns
The materialized result of running the command, in addition to a future signaling when the command is done running.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])