java.lang.Object
- csw.command.api.client.CommandServiceClient

All Implemented Interfaces:

CommandServiceCodecs, csw.command.api.scaladsl.CommandService, ParamCodecs, ParamCodecsBase, CommonCodecs, msocket.api.codecs.BasicCodecs
```
public class CommandServiceClient
extends java.lang.Object
implements csw.command.api.scaladsl.CommandService, CommandServiceCodecs
```

Nested Class Summary
- Nested classes/interfaces inherited from interface csw.prefix.codecs.CommonCodecs
  CommonCodecs.Timestamp, CommonCodecs.Timestamp$

Constructor Summary

Constructors
Constructor	Description
`CommandServiceClient(msocket.api.Transport<CommandServiceRequest> httpTransport, msocket.api.Transport<CommandServiceStreamRequest> websocketTransport, akka.actor.typed.ActorSystem<?> actorSystem)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`io.bullet.borer.Codec<Angle>`	`angleCodec()`
`io.bullet.borer.Decoder<byte[]>`	`bytesDec()`
`io.bullet.borer.Encoder<byte[]>`	`bytesEnc()`
`io.bullet.borer.Decoder<java.lang.Object>`	`charDec()`
`io.bullet.borer.Encoder<java.lang.Object>`	`charEnc()`
`io.bullet.borer.Codec<Choice>`	`choiceCodec()`
`io.bullet.borer.Codec<CommandIssue>`	`commandIssueCodecValue()`
`io.bullet.borer.Codec<CommandName>`	`commandNameCodec()`
`io.bullet.borer.Codec<CommandResponse>`	`commandResponseCodecValue()`
`msocket.api.ErrorProtocol<CommandServiceRequest>`	`CommandServiceHttpErrorProtocol()`
`msocket.api.ErrorProtocol<CommandServiceStreamRequest>`	`CommandServiceWebsocketErrorProtocol()`
`io.bullet.borer.Codec<ControlCommand>`	`controlCommandCodec()`
`io.bullet.borer.Codec<Coords.Coord>`	`coordCodecValue()`
`io.bullet.borer.Codec<CurrentState>`	`currentStateCodecValue()`
`io.bullet.borer.Codec<akka.Done>`	`doneCodec()`
`io.bullet.borer.Codec<Event>`	`eventCodec()`
`io.bullet.borer.Codec<EventName>`	`eventNameCodec()`
`io.bullet.borer.Codec<scala.concurrent.duration.FiniteDuration>`	`finiteDurationCodec()`
`io.bullet.borer.AdtEncodingStrategy`	`flatAdtEncoding()`
`io.bullet.borer.Codec<CommandServiceRequest>`	`httpCodecsValue()`
`io.bullet.borer.Codec<Id>`	`idCodec()`
`io.bullet.borer.Decoder<java.time.Instant>`	`instantDec()`
`io.bullet.borer.Encoder<java.time.Instant>`	`instantEnc()`
`io.bullet.borer.Decoder<java.lang.Byte[]>`	`javaByteArrayDec()`
`io.bullet.borer.Encoder<java.lang.Byte[]>`	`javaByteArrayEnc()`
`io.bullet.borer.Codec<ObsId>`	`obsIdCodec()`
`scala.concurrent.Future<CommandResponse.OnewayResponse>`	`oneway(ControlCommand controlCommand)`
`scala.concurrent.Future<CommandResponse.MatchingResponse>`	`onewayAndMatch(ControlCommand controlCommand, StateMatcher stateMatcher)`
`io.bullet.borer.Decoder<Parameter<?>>`	`paramDecExistential()`
`io.bullet.borer.Encoder<Parameter<?>>`	`paramEncExistential()`
`io.bullet.borer.Codec<Prefix>`	`prefixCodec()`
`io.bullet.borer.Codec<ProperMotion>`	`properMotionCodec()`
`scala.concurrent.Future<CommandResponse.SubmitResponse>`	`query(Id commandRunId)`
`scala.concurrent.Future<CommandResponse.SubmitResponse>`	`queryFinal(Id commandRunId, akka.util.Timeout timeout)`
`io.bullet.borer.Codec<RaDec>`	`raDecCodec()`
`io.bullet.borer.Codec<Result>`	`resultCodec()`
`io.bullet.borer.Codec<Sequence>`	`sequenceCodec()`
`io.bullet.borer.Codec<SequenceCommand>`	`sequenceCommandCodec()`
`io.bullet.borer.Codec<StateName>`	`stateNameCodec()`
`io.bullet.borer.Codec<StateVariable>`	`stateVariableCodecValue()`
`io.bullet.borer.Codec<Struct>`	`structCodec()`
`scala.concurrent.Future<CommandResponse.SubmitResponse>`	`submit(ControlCommand controlCommand)`
`scala.concurrent.Future<scala.collection.immutable.List<CommandResponse.SubmitResponse>>`	`submitAllAndWait(scala.collection.immutable.List<ControlCommand> submitCommands, akka.util.Timeout timeout)`
`scala.concurrent.Future<CommandResponse.SubmitResponse>`	`submitAndWait(ControlCommand controlCommand, akka.util.Timeout timeout)`
`akka.stream.scaladsl.Source<CurrentState,msocket.api.Subscription>`	`subscribeCurrentState(scala.collection.immutable.Set<StateName> names)`
`msocket.api.Subscription`	`subscribeCurrentState(scala.collection.immutable.Set<StateName> names, scala.Function1<CurrentState,scala.runtime.BoxedUnit> callback)`
`msocket.api.Subscription`	`subscribeCurrentState(scala.Function1<CurrentState,scala.runtime.BoxedUnit> callback)`
`io.bullet.borer.Codec<Coords.Tag>`	`tagCodec()`
`io.bullet.borer.Codec<TAITime>`	`taiTimeCodec()`
`io.bullet.borer.Codec<akka.util.Timeout>`	`timeoutInSecondsCodec()`
`CommonCodecs.Timestamp$`	`Timestamp()`
`io.bullet.borer.Codec<UTCTime>`	`utcTimeCodec()`
`scala.concurrent.Future<CommandResponse.ValidateResponse>`	`validate(ControlCommand controlCommand)`
`io.bullet.borer.Codec<CommandServiceStreamRequest>`	`websocketCodecs()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface msocket.api.codecs.BasicCodecs
eitherCodec

Methods inherited from interface csw.command.api.scaladsl.CommandService
subscribeCurrentState$default$1

Methods inherited from interface csw.prefix.codecs.CommonCodecs
enumCodec

Methods inherited from interface csw.params.core.formats.ParamCodecs
commandResponseCodec, coordCodec

Methods inherited from interface csw.params.core.formats.ParamCodecsBase
arrayDataCodec, matrixDataCodec, paramCodec, paramCoreCodec, waCodec

Constructor Detail

CommandServiceClient

public CommandServiceClient(msocket.api.Transport<CommandServiceRequest> httpTransport,
                            msocket.api.Transport<CommandServiceStreamRequest> websocketTransport,
                            akka.actor.typed.ActorSystem<?> actorSystem)

Method Detail

CommandServiceHttpErrorProtocol
```
public msocket.api.ErrorProtocol<CommandServiceRequest> CommandServiceHttpErrorProtocol()
```
Specified by:

CommandServiceHttpErrorProtocol in interface CommandServiceCodecs

CommandServiceWebsocketErrorProtocol
```
public msocket.api.ErrorProtocol<CommandServiceStreamRequest> CommandServiceWebsocketErrorProtocol()
```
Specified by:

CommandServiceWebsocketErrorProtocol in interface CommandServiceCodecs

Timestamp

public CommonCodecs.Timestamp$ Timestamp()

angleCodec
```
public io.bullet.borer.Codec<Angle> angleCodec()
```
Specified by:

angleCodec in interface ParamCodecsBase

bytesDec
```
public io.bullet.borer.Decoder<byte[]> bytesDec()
```
Specified by:

bytesDec in interface ParamCodecsBase

bytesEnc
```
public io.bullet.borer.Encoder<byte[]> bytesEnc()
```
Specified by:

bytesEnc in interface ParamCodecsBase

charDec

public io.bullet.borer.Decoder<java.lang.Object> charDec()

Specified by:: charDec in interface ParamCodecsBase

charEnc

public io.bullet.borer.Encoder<java.lang.Object> charEnc()

Specified by:: charEnc in interface ParamCodecsBase

choiceCodec
```
public io.bullet.borer.Codec<Choice> choiceCodec()
```
Specified by:

choiceCodec in interface ParamCodecsBase

commandIssueCodecValue
```
public io.bullet.borer.Codec<CommandIssue> commandIssueCodecValue()
```
Specified by:

commandIssueCodecValue in interface ParamCodecsBase

commandNameCodec
```
public io.bullet.borer.Codec<CommandName> commandNameCodec()
```
Specified by:

commandNameCodec in interface ParamCodecsBase

commandResponseCodecValue
```
public io.bullet.borer.Codec<CommandResponse> commandResponseCodecValue()
```
Specified by:

commandResponseCodecValue in interface ParamCodecsBase

controlCommandCodec
```
public io.bullet.borer.Codec<ControlCommand> controlCommandCodec()
```
Specified by:

controlCommandCodec in interface ParamCodecsBase

coordCodecValue
```
public io.bullet.borer.Codec<Coords.Coord> coordCodecValue()
```
Specified by:

coordCodecValue in interface ParamCodecsBase

currentStateCodecValue
```
public io.bullet.borer.Codec<CurrentState> currentStateCodecValue()
```
Specified by:

currentStateCodecValue in interface ParamCodecsBase

doneCodec
```
public io.bullet.borer.Codec<akka.Done> doneCodec()
```
Specified by:

doneCodec in interface msocket.api.codecs.BasicCodecs

eventCodec
```
public io.bullet.borer.Codec<Event> eventCodec()
```
Specified by:

eventCodec in interface ParamCodecsBase

eventNameCodec
```
public io.bullet.borer.Codec<EventName> eventNameCodec()
```
Specified by:

eventNameCodec in interface ParamCodecsBase

finiteDurationCodec

public io.bullet.borer.Codec<scala.concurrent.duration.FiniteDuration> finiteDurationCodec()

Specified by:: finiteDurationCodec in interface CommonCodecs

flatAdtEncoding
```
public io.bullet.borer.AdtEncodingStrategy flatAdtEncoding()
```
Specified by:

flatAdtEncoding in interface CommonCodecs

httpCodecsValue
```
public io.bullet.borer.Codec<CommandServiceRequest> httpCodecsValue()
```
Specified by:

httpCodecsValue in interface CommandServiceCodecs

idCodec
```
public io.bullet.borer.Codec<Id> idCodec()
```
Specified by:

idCodec in interface ParamCodecsBase

instantDec

public io.bullet.borer.Decoder<java.time.Instant> instantDec()

Specified by:: instantDec in interface CommonCodecs

instantEnc

public io.bullet.borer.Encoder<java.time.Instant> instantEnc()

Specified by:: instantEnc in interface CommonCodecs

javaByteArrayDec
```
public io.bullet.borer.Decoder<java.lang.Byte[]> javaByteArrayDec()
```
Specified by:

javaByteArrayDec in interface ParamCodecsBase

javaByteArrayEnc
```
public io.bullet.borer.Encoder<java.lang.Byte[]> javaByteArrayEnc()
```
Specified by:

javaByteArrayEnc in interface ParamCodecsBase

obsIdCodec
```
public io.bullet.borer.Codec<ObsId> obsIdCodec()
```
Specified by:

obsIdCodec in interface ParamCodecsBase

oneway

public scala.concurrent.Future<CommandResponse.OnewayResponse> oneway(ControlCommand controlCommand)

Specified by:: oneway in interface csw.command.api.scaladsl.CommandService

onewayAndMatch

public scala.concurrent.Future<CommandResponse.MatchingResponse> onewayAndMatch(ControlCommand controlCommand,
                                                                                StateMatcher stateMatcher)

Specified by:: onewayAndMatch in interface csw.command.api.scaladsl.CommandService

paramDecExistential
```
public io.bullet.borer.Decoder<Parameter<?>> paramDecExistential()
```
Specified by:

paramDecExistential in interface ParamCodecsBase

paramEncExistential
```
public io.bullet.borer.Encoder<Parameter<?>> paramEncExistential()
```
Specified by:

paramEncExistential in interface ParamCodecsBase

prefixCodec
```
public io.bullet.borer.Codec<Prefix> prefixCodec()
```
Specified by:

prefixCodec in interface CommonCodecs

properMotionCodec
```
public io.bullet.borer.Codec<ProperMotion> properMotionCodec()
```
Specified by:

properMotionCodec in interface ParamCodecsBase

query

public scala.concurrent.Future<CommandResponse.SubmitResponse> query(Id commandRunId)

Specified by:: query in interface csw.command.api.scaladsl.CommandService

queryFinal

public scala.concurrent.Future<CommandResponse.SubmitResponse> queryFinal(Id commandRunId,
                                                                          akka.util.Timeout timeout)

Specified by:: queryFinal in interface csw.command.api.scaladsl.CommandService

raDecCodec
```
public io.bullet.borer.Codec<RaDec> raDecCodec()
```
Specified by:

raDecCodec in interface ParamCodecsBase

resultCodec
```
public io.bullet.borer.Codec<Result> resultCodec()
```
Specified by:

resultCodec in interface ParamCodecsBase

sequenceCodec
```
public io.bullet.borer.Codec<Sequence> sequenceCodec()
```
Specified by:

sequenceCodec in interface ParamCodecsBase

sequenceCommandCodec
```
public io.bullet.borer.Codec<SequenceCommand> sequenceCommandCodec()
```
Specified by:

sequenceCommandCodec in interface ParamCodecsBase

stateNameCodec
```
public io.bullet.borer.Codec<StateName> stateNameCodec()
```
Specified by:

stateNameCodec in interface ParamCodecsBase

stateVariableCodecValue
```
public io.bullet.borer.Codec<StateVariable> stateVariableCodecValue()
```
Specified by:

stateVariableCodecValue in interface ParamCodecsBase

structCodec
```
public io.bullet.borer.Codec<Struct> structCodec()
```
Specified by:

structCodec in interface ParamCodecsBase

submit

public scala.concurrent.Future<CommandResponse.SubmitResponse> submit(ControlCommand controlCommand)

Specified by:: submit in interface csw.command.api.scaladsl.CommandService

submitAllAndWait

public scala.concurrent.Future<scala.collection.immutable.List<CommandResponse.SubmitResponse>> submitAllAndWait(scala.collection.immutable.List<ControlCommand> submitCommands,
                                                                                                                 akka.util.Timeout timeout)

Specified by:: submitAllAndWait in interface csw.command.api.scaladsl.CommandService

submitAndWait

public scala.concurrent.Future<CommandResponse.SubmitResponse> submitAndWait(ControlCommand controlCommand,
                                                                             akka.util.Timeout timeout)

Specified by:: submitAndWait in interface csw.command.api.scaladsl.CommandService

subscribeCurrentState

public akka.stream.scaladsl.Source<CurrentState,msocket.api.Subscription> subscribeCurrentState(scala.collection.immutable.Set<StateName> names)

Specified by:: subscribeCurrentState in interface csw.command.api.scaladsl.CommandService

subscribeCurrentState

public msocket.api.Subscription subscribeCurrentState(scala.Function1<CurrentState,scala.runtime.BoxedUnit> callback)

Specified by:: subscribeCurrentState in interface csw.command.api.scaladsl.CommandService

subscribeCurrentState

public msocket.api.Subscription subscribeCurrentState(scala.collection.immutable.Set<StateName> names,
                                                      scala.Function1<CurrentState,scala.runtime.BoxedUnit> callback)

Specified by:: subscribeCurrentState in interface csw.command.api.scaladsl.CommandService

tagCodec
```
public io.bullet.borer.Codec<Coords.Tag> tagCodec()
```
Specified by:

tagCodec in interface ParamCodecsBase

taiTimeCodec
```
public io.bullet.borer.Codec<TAITime> taiTimeCodec()
```
Specified by:

taiTimeCodec in interface ParamCodecsBase

timeoutInSecondsCodec
```
public io.bullet.borer.Codec<akka.util.Timeout> timeoutInSecondsCodec()
```
Specified by:

timeoutInSecondsCodec in interface msocket.api.codecs.BasicCodecs

utcTimeCodec
```
public io.bullet.borer.Codec<UTCTime> utcTimeCodec()
```
Specified by:

utcTimeCodec in interface ParamCodecsBase

validate

public scala.concurrent.Future<CommandResponse.ValidateResponse> validate(ControlCommand controlCommand)

Specified by:: validate in interface csw.command.api.scaladsl.CommandService

websocketCodecs

public io.bullet.borer.Codec<CommandServiceStreamRequest> websocketCodecs()

Specified by:: websocketCodecs in interface CommandServiceCodecs

Class CommandServiceClient

Nested Class Summary

Nested classes/interfaces inherited from interface csw.prefix.codecs.CommonCodecs

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface msocket.api.codecs.BasicCodecs

Methods inherited from interface csw.command.api.scaladsl.CommandService

Methods inherited from interface csw.prefix.codecs.CommonCodecs

Methods inherited from interface csw.params.core.formats.ParamCodecs

Methods inherited from interface csw.params.core.formats.ParamCodecsBase

Constructor Detail

CommandServiceClient

Method Detail

CommandServiceHttpErrorProtocol

CommandServiceWebsocketErrorProtocol

Timestamp

angleCodec

bytesDec

bytesEnc

charDec

charEnc

choiceCodec

commandIssueCodecValue

commandNameCodec

commandResponseCodecValue

controlCommandCodec

coordCodecValue

currentStateCodecValue

doneCodec

eventCodec

eventNameCodec

finiteDurationCodec

flatAdtEncoding

httpCodecsValue

idCodec

instantDec

instantEnc

javaByteArrayDec

javaByteArrayEnc

obsIdCodec

oneway

onewayAndMatch

paramDecExistential

paramEncExistential

prefixCodec

properMotionCodec

query

queryFinal

raDecCodec

resultCodec

sequenceCodec

sequenceCommandCodec

stateNameCodec

stateVariableCodecValue

structCodec

submit

submitAllAndWait

submitAndWait

subscribeCurrentState

subscribeCurrentState

subscribeCurrentState

tagCodec

taiTimeCodec

timeoutInSecondsCodec

utcTimeCodec

validate

websocketCodecs