Package org.cometd.server.http

Class AsyncJSONTransport.AbstractReader

java.lang.Object

org.cometd.server.http.AsyncJSONTransport.AbstractReader

All Implemented Interfaces:

jakarta.servlet.ReadListener, EventListener

Direct Known Subclasses:

AsyncJSONTransport.CharsetReader, AsyncJSONTransport.UTF8Reader

Enclosing class:

AsyncJSONTransport

protected abstract class AsyncJSONTransport.AbstractReader
extends Object
implements jakarta.servlet.ReadListener

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractReader(AbstractHttpTransport.Context context, Promise<Void> promise)

Method Summary

Modifier and Type	Method	Description
protected abstract void	append(byte[] buffer, int offset, int length)
protected void	finish(String json)
protected void	finish(List<ServerMessage.Mutable> messages)
void	onDataAvailable()
void	onError(Throwable failure)

Methods inherited from class java.lang.Object

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

Methods inherited from interface jakarta.servlet.ReadListener

onAllDataRead

Constructor Details

AbstractReader

protected AbstractReader(AbstractHttpTransport.Context context,
 Promise<Void> promise)

Method Details

onDataAvailable

public void onDataAvailable()
                     throws IOException

Specified by:

onDataAvailable in interface jakarta.servlet.ReadListener

Throws:

IOException

append

protected abstract void append(byte[] buffer,
 int offset,
 int length)

finish

protected void finish(List<ServerMessage.Mutable> messages)
               throws IOException

Throws:

IOException

finish

protected void finish(String json)
               throws IOException

Throws:

IOException

onError

public void onError(Throwable failure)

Specified by:

onError in interface jakarta.servlet.ReadListener