Package net.thevpc.naru.impl.interaction

Class NaruStreamInteraction

java.lang.Object

net.thevpc.naru.impl.interaction.NaruStreamInteraction

All Implemented Interfaces:

NaruInteraction

public class NaruStreamInteraction
extends Object
implements NaruInteraction

The headless implementation: no terminal, no thread, output forwarded to a listener.

This is the one a server embeds. A web front end hands each session a listener that pushes NaruOutput onto an SSE stream or a websocket, and answers NaruInputRequests whenever the user submits a line — possibly from a different process, minutes later.

Nothing is dropped on the floor

An input request is published to an NaruStreamInteraction.InputListener and then held until it is delivered or cancelled, because there is no reader thread to pick it up. That is the whole point: the host owns the lifecycle, and the core waits. A host that never answers leaves the task blocked, which is the honest outcome and is preferable to inventing a default answer.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	NaruStreamInteraction.InputListener	Receives the input requests this interaction wants answered.
static interface	NaruStreamInteraction.OutputListener	Receives every piece of session output, in emission order per session.

Field Summary

Fields inherited from interface net.thevpc.naru.api.agent.NaruInteraction

NAME_STREAM, NAME_TERMINAL

Constructor Summary

Constructors

Constructor	Description
NaruStreamInteraction(NaruStreamInteraction.OutputListener listener)
NaruStreamInteraction(NaruStreamInteraction.OutputListener listener, NaruStreamInteraction.InputListener inputListener)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the interaction and fails any request still waiting, so a host shutting the session down unblocks its workers instead of leaving them parked.
String	name()
void	open(NaruSession session)
void	requestInput(NaruInputRequest request)	Hands the request to the host and returns immediately.
NaruStreamInteraction	withInputListener(NaruStreamInteraction.InputListener inputListener)
void	write(NaruLogMode mode, net.thevpc.nuts.text.NMsg message)
void	writeStream(NaruLogMode mode, net.thevpc.nuts.text.NMsg fragment, boolean end)	Joins streamed fragments and reports them as one output when the stream ends.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NaruStreamInteraction

public NaruStreamInteraction(NaruStreamInteraction.OutputListener listener)

NaruStreamInteraction

public NaruStreamInteraction(NaruStreamInteraction.OutputListener listener,
 NaruStreamInteraction.InputListener inputListener)

Method Details

withInputListener

public NaruStreamInteraction withInputListener(NaruStreamInteraction.InputListener inputListener)

name

public String name()

Specified by:

name in interface NaruInteraction

open

public void open(NaruSession session)

Specified by:

open in interface NaruInteraction

requestInput

public void requestInput(NaruInputRequest request)

Hands the request to the host and returns immediately.

Nothing is blocked here. The task is already parked in BLOCKED_ON_INPUT and simply stays there until the host calls NaruInputRequest.deliver(String) or NaruInputRequest.cancel(String), so the answer may come from any thread, any later request, or another process.

Specified by:

requestInput in interface NaruInteraction

write

public void write(NaruLogMode mode,
 net.thevpc.nuts.text.NMsg message)

Specified by:

write in interface NaruInteraction

writeStream

public void writeStream(NaruLogMode mode,
 net.thevpc.nuts.text.NMsg fragment,
 boolean end)

Joins streamed fragments and reports them as one output when the stream ends.

A host consuming NaruOutput gets whole messages and can render them as complete units -- a half-sentence per event would be useless to it. If it wants token-level updates it should consume the model's stream directly; this interaction is the log of what happened, not the wire.

Specified by:

writeStream in interface NaruInteraction

close

public void close()

Closes the interaction and fails any request still waiting, so a host shutting the session down unblocks its workers instead of leaving them parked.

Specified by:

close in interface NaruInteraction