Class StreamSender

java.lang.Object
arc.net.TcpIdleSender
arc.net.InputStreamSender
com.xpdustry.claj.common.net.stream.StreamSender
All Implemented Interfaces:
arc.net.NetListener
public class StreamSender extends arc.net.InputStreamSender
invalid reference 
mindustry.net.ArcNetProvider.ArcConnection#sendStream(mindustry.net.Streamable)
.

Note: StreamHead and StreamChunk must be registered in ClajNet.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface arc.net.NetListener

    arc.net.NetListener.LagListener, arc.net.NetListener.QueuedListener, arc.net.NetListener.ThreadedListener

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    final int
    chunkSize
     
    final boolean
    compressed
     
    final arc.net.Connection
    connection
     
    protected int
    id
     
    final InputStream
    input
     
    final int
    length
     
    final byte
    type
     
    protected int
    written
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    StreamSender(arc.net.Connection connection, InputStream stream, byte type, int length, int chunkSize, boolean isCompressed)
    Stream is directly started.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected Object
    next(byte[] bytes)
     
    static PreparedStream
    prepare(Packet packet)
     
    static PreparedStream
    prepare(Packet packet, boolean compress)
     
    static PreparedStream
    prepare(Packet packet, int chunkSize, boolean compress)
     
    static StreamSender
    send(arc.net.Connection connection, Packet packet)
     
    static StreamSender
    send(arc.net.Connection connection, Packet packet, boolean compress)
     
    static StreamSender
    send(arc.net.Connection connection, Packet packet, int chunkSize, boolean compress)
     
    protected void
    start()
     

    Methods inherited from class arc.net.InputStreamSender

    next

    Methods inherited from class arc.net.TcpIdleSender

    idle

    Methods inherited from class Object

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

    Methods inherited from interface arc.net.NetListener

    connected, disconnected, received

  • Field Details

    • connection

      public final arc.net.Connection connection

    • input

      public final InputStream input

    • type

      public final byte type

    • length

      public final int length

    • chunkSize

      public final int chunkSize

    • compressed

      public final boolean compressed

    • id

      protected int id

    • written

      protected int written

  • Constructor Details

    • StreamSender

      public StreamSender(arc.net.Connection connection, InputStream stream, byte type, int length, int chunkSize, boolean isCompressed)
      Stream is directly started.

  • Method Details

    • start

      protected void start()
      Overrides:
      start in class arc.net.TcpIdleSender

    • next

      protected Object next(byte[] bytes)
      Specified by:
      next in class arc.net.InputStreamSender

    • send

      public static StreamSender send(arc.net.Connection connection, Packet packet)

    • send

      public static StreamSender send(arc.net.Connection connection, Packet packet, boolean compress)

    • send

      public static StreamSender send(arc.net.Connection connection, Packet packet, int chunkSize, boolean compress)

    • prepare

      public static PreparedStream prepare(Packet packet)

    • prepare

      public static PreparedStream prepare(Packet packet, boolean compress)

    • prepare

      public static PreparedStream prepare(Packet packet, int chunkSize, boolean compress)