Class CompressedQuicTripTransport

All Implemented Interfaces:
Transport

@TransportService("tripcq") public class CompressedQuicTripTransport extends QuicTripTransport
Transport implementation for QUIC with compression.
  • Field Details

  • Constructor Details

    • CompressedQuicTripTransport

      public CompressedQuicTripTransport(URI uri)
      Creates a new compressed QUIC transport.
      Parameters:
      uri - the URI of the transport
  • Method Details

    • createConnectionHandler

      public Runnable createConnectionHandler(String connectionName, InputStream inputStream, OutputStream outputStream)
      Description copied from interface: Transport
      Creates a connection handler for the given streams.
      Specified by:
      createConnectionHandler in interface Transport
      Overrides:
      createConnectionHandler in class AbstractTransport
      Parameters:
      connectionName - the name of the connection
      inputStream - the input stream
      outputStream - the output stream
      Returns:
      the connection handler
    • createStream

      public TripStream createStream(Dictionary dictionary, tech.kwik.core.QuicStream quicStream)
      Description copied from class: QuicTripTransport
      Creates a trip stream for the given QUIC stream.
      Overrides:
      createStream in class QuicTripTransport
      Parameters:
      dictionary - the dictionary to use for serialization/deserialization
      quicStream - the QUIC stream
      Returns:
      the trip stream
    • createCompressedOutputStream

      protected OutputStream createCompressedOutputStream(OutputStream outputStream)
      Creates the compressed output stream.
      Parameters:
      outputStream - the uncompressed output stream from the socket
      Returns:
      the compressed output stream
    • createCompressedInputStream

      protected InputStream createCompressedInputStream(InputStream inputStream)
      Creates the compressed input stream.
      Parameters:
      inputStream - the uncompressed input stream from the socket
      Returns:
      the compressed input stream