Uses of Interface
com.google.genkit.core.InputSource

Packages that use InputSource

Package	Description
com.google.genkit.ai.agent	This package provides types for the Genkit agents feature, including enums and models for agent state snapshots, agent execution lifecycle, and agent-related operations.
com.google.genkit.core

Uses of InputSource in com.google.genkit.ai.agent

Methods in com.google.genkit.ai.agent with parameters of type InputSource

Modifier and Type	Method	Description
AgentOutput<S>	Agent.runBidi(ActionContext ctx, AgentInit<S> init, InputSource<AgentInput> inputs, Consumer<AgentStreamChunk> streamCallback)
com.fasterxml.jackson.databind.JsonNode	Agent.runBidiJson(ActionContext ctx, com.fasterxml.jackson.databind.JsonNode init, InputSource<com.fasterxml.jackson.databind.JsonNode> inputs, Consumer<com.fasterxml.jackson.databind.JsonNode> streamCallback)
ActionRunResult<com.fasterxml.jackson.databind.JsonNode>	Agent.runBidiJsonWithTelemetry(ActionContext ctx, com.fasterxml.jackson.databind.JsonNode init, InputSource<com.fasterxml.jackson.databind.JsonNode> inputs, Consumer<com.fasterxml.jackson.databind.JsonNode> streamCallback)

Uses of InputSource in com.google.genkit.core

Classes in com.google.genkit.core that implement InputSource

Modifier and Type	Class	Description
final class	BufferedInputSource<I>	A thread-safe InputSource that is fed by a producer via BufferedInputSource.offer(I) and signals end-of-stream via BufferedInputSource.end().

Methods in com.google.genkit.core with parameters of type InputSource

Modifier and Type	Method	Description
O	BidiAction.BidiHandler.handle(ActionContext ctx, Init init, InputSource<I> inputs, Consumer<S> streamCallback)	Handles one invocation of the bidirectional action.
O	BidiAction.runBidi(ActionContext ctx, Init init, InputSource<I> inputs, Consumer<S> streamCallback)	Runs the action in bidirectional-streaming mode.
O	BidiActionImpl.runBidi(ActionContext ctx, Init init, InputSource<I> inputs, Consumer<S> streamCallback)
com.fasterxml.jackson.databind.JsonNode	BidiAction.runBidiJson(ActionContext ctx, com.fasterxml.jackson.databind.JsonNode init, InputSource<com.fasterxml.jackson.databind.JsonNode> inputs, Consumer<com.fasterxml.jackson.databind.JsonNode> streamCallback)	Runs the action in bidirectional-streaming mode with JSON-typed arguments.
com.fasterxml.jackson.databind.JsonNode	BidiActionImpl.runBidiJson(ActionContext ctx, com.fasterxml.jackson.databind.JsonNode init, InputSource<com.fasterxml.jackson.databind.JsonNode> inputs, Consumer<com.fasterxml.jackson.databind.JsonNode> streamCallback)
ActionRunResult<com.fasterxml.jackson.databind.JsonNode>	BidiAction.runBidiJsonWithTelemetry(ActionContext ctx, com.fasterxml.jackson.databind.JsonNode init, InputSource<com.fasterxml.jackson.databind.JsonNode> inputs, Consumer<com.fasterxml.jackson.databind.JsonNode> streamCallback)	Runs the action in bidirectional-streaming mode with JSON-typed arguments and telemetry.
ActionRunResult<com.fasterxml.jackson.databind.JsonNode>	BidiActionImpl.runBidiJsonWithTelemetry(ActionContext ctx, com.fasterxml.jackson.databind.JsonNode init, InputSource<com.fasterxml.jackson.databind.JsonNode> inputs, Consumer<com.fasterxml.jackson.databind.JsonNode> streamCallback)