Class TokenStreamToPublisherAdapter

java.lang.Object

io.micronaut.langchain4j.aiservices.TokenStreamToPublisherAdapter

All Implemented Interfaces:

dev.langchain4j.spi.services.TokenStreamAdapter

@Internal
public final class TokenStreamToPublisherAdapter
extends Object
implements dev.langchain4j.spi.services.TokenStreamAdapter

Lets AI service methods return a Reactive Streams Publisher<String>, the reactive type of the Micronaut APIs, with any streaming chat model: the partial responses are streamed like with Reactor's Flux<String>, which langchain4j-reactor supports and which is the Publisher returned.

Constructor Summary

Constructors

Constructor	Description
TokenStreamToPublisherAdapter()

Method Summary

Modifier and Type	Method	Description
Object	adapt(dev.langchain4j.service.TokenStream tokenStream)
boolean	canAdaptTokenStreamTo(Type type)

Methods inherited from class Object

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

Constructor Details

TokenStreamToPublisherAdapter

public TokenStreamToPublisherAdapter()

Method Details

canAdaptTokenStreamTo

public boolean canAdaptTokenStreamTo(Type type)

Specified by:

canAdaptTokenStreamTo in interface dev.langchain4j.spi.services.TokenStreamAdapter

adapt

public Object adapt(dev.langchain4j.service.TokenStream tokenStream)

Specified by:

adapt in interface dev.langchain4j.spi.services.TokenStreamAdapter