Class NettyPythonEventLoop.NettySocketTransport

java.lang.Object

io.micronaut.context.python.netty.NettyPythonEventLoop.NettyTransport

io.micronaut.context.python.netty.NettyPythonEventLoop.NettySocketTransport

Enclosing class:

NettyPythonEventLoop

public static final class NettyPythonEventLoop.NettySocketTransport
extends NettyPythonEventLoop.NettyTransport

Netty-backed stream transport exposed to Python as a host object.

The snake_case methods are intentionally duplicated alongside Java-style methods. GraalPy member lookup is name based, and asyncio's transports call names such as get_extra_info, pause_reading, and is_closing. The Checkstyle suppression below protects that Python-facing contract.

Field Summary

Fields inherited from class NettyPythonEventLoop.NettyTransport

channel, closing, protocol, support

Method Summary

Modifier and Type	Method	Description
boolean	can_write_eof()
boolean	canWriteEof()
Object[]	get_write_buffer_limits()
int	get_write_buffer_size()
@Nullable Object	getExtraInfo(String name, @Nullable Object defaultValue)
Object[]	getWriteBufferLimits()
int	getWriteBufferSize()
boolean	is_reading()
boolean	isReading()
void	pause_reading()
void	pauseReading()
void	resume_reading()
void	resumeReading()
void	set_write_buffer_limits(@Nullable Integer high, @Nullable Integer low)
void	setWriteBufferLimits(@Nullable Integer high, @Nullable Integer low)
void	write(byte[] bytes)
void	write_eof()
void	writeEof()
void	writelines(org.graalvm.polyglot.Value lines)

Methods inherited from class NettyPythonEventLoop.NettyTransport

abort, close, get_extra_info, get_extra_info, get_protocol, getExtraInfo, getProtocol, is_closing, isClosing, set_protocol, setProtocol

Methods inherited from class Object

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

Method Details

write

public void write(byte[] bytes)

writelines

public void writelines(org.graalvm.polyglot.Value lines)

canWriteEof

public boolean canWriteEof()

can_write_eof

public boolean can_write_eof()

writeEof

public void writeEof()

write_eof

public void write_eof()

getWriteBufferSize

public int getWriteBufferSize()

get_write_buffer_size

public int get_write_buffer_size()

getWriteBufferLimits

public Object[] getWriteBufferLimits()

get_write_buffer_limits

public Object[] get_write_buffer_limits()

setWriteBufferLimits

public void setWriteBufferLimits(@Nullable Integer high,
 @Nullable Integer low)

set_write_buffer_limits

public void set_write_buffer_limits(@Nullable Integer high,
 @Nullable Integer low)

isReading

public boolean isReading()

is_reading

public boolean is_reading()

pauseReading

public void pauseReading()

pause_reading

public void pause_reading()

resumeReading

public void resumeReading()

resume_reading

public void resume_reading()

getExtraInfo

public @Nullable Object getExtraInfo(String name,
 @Nullable Object defaultValue)

Specified by:

getExtraInfo in class NettyPythonEventLoop.NettyTransport