Package org.red5.server.net.rtmp

Class RTMPChannelFilter.DirectOutput

java.lang.Object
org.red5.server.net.rtmp.RTMPChannelFilter.DirectOutput
All Implemented Interfaces:
org.apache.mina.filter.codec.ProtocolEncoderOutput
Enclosing class:
RTMPChannelFilter
private static class RTMPChannelFilter.DirectOutput extends Object implements org.apache.mina.filter.codec.ProtocolEncoderOutput

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final org.apache.mina.core.filterchain.IoFilter.NextFilter
    nextFilter
     
    private final org.apache.mina.core.session.IoSession
    session
     
    private final org.apache.mina.core.write.WriteRequest
    writeRequest
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    DirectOutput(org.apache.mina.core.session.IoSession session, org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter, org.apache.mina.core.write.WriteRequest writeRequest)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.mina.core.future.WriteFuture
    flush()
     
    void
    mergeAll()
     
    void
    write(Object encodedMessage)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • session

      private final org.apache.mina.core.session.IoSession session

    • nextFilter

      private final org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter

    • writeRequest

      private final org.apache.mina.core.write.WriteRequest writeRequest

  • Constructor Details

    • DirectOutput

      public DirectOutput(org.apache.mina.core.session.IoSession session, org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter, org.apache.mina.core.write.WriteRequest writeRequest)

  • Method Details

    • write

      public void write(Object encodedMessage)
      Specified by:
      write in interface org.apache.mina.filter.codec.ProtocolEncoderOutput

    • flush

      public org.apache.mina.core.future.WriteFuture flush()
      Specified by:
      flush in interface org.apache.mina.filter.codec.ProtocolEncoderOutput

    • mergeAll

      public void mergeAll()
      Specified by:
      mergeAll in interface org.apache.mina.filter.codec.ProtocolEncoderOutput