Observable Command

Observable commands can be subscribed. During the subscription, intermediate results can be returned that contain information on the command execution status, such as remaining execution time, progress and intermediate result data. Add the ObservableCommand decorator to a method to turn it into an unobservable command.

@sila.ObservableCommand()
@sila.Response(name="FinalResponse")
@sila.IntermediateResponse(name="Current Iteration")
async def response_after_countdown(iterations: int, *, status: sila.Status, intermediate: sila.Intermediate[int]):
    """ Creates a random number based on a seed input. """
    ...

🧱🚧🏗️ Coming soon: Yielding and returning responses with observables 🧱🚧🏗️