org.eclipse.jetty.io.Buffer.asReadOnlyBuffer()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(3.2k)|赞(0)|评价(0)|浏览(95)

本文整理了Java中org.eclipse.jetty.io.Buffer.asReadOnlyBuffer()方法的一些代码示例,展示了Buffer.asReadOnlyBuffer()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Buffer.asReadOnlyBuffer()方法的具体详情如下:
包路径:org.eclipse.jetty.io.Buffer
类名称:Buffer
方法名:asReadOnlyBuffer

Buffer.asReadOnlyBuffer介绍

暂无

代码示例

代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-plus

public void notifyIncoming(Buffer buffer, int read)
{
  if (listeners != null && !listeners.isEmpty() && read > 0)
  {
    for (NetworkTrafficListener listener : listeners)
    {
      try
      {
        Buffer view = buffer.asReadOnlyBuffer();
        listener.incoming(_socket, view);
      }
      catch (Exception x)
      {
        LOG.warn(x);
      }
    }
  }
}

代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-all-server

public void notifyIncoming(Buffer buffer, int read)
{
  if (listeners != null && !listeners.isEmpty() && read > 0)
  {
    for (NetworkTrafficListener listener : listeners)
    {
      try
      {
        Buffer view = buffer.asReadOnlyBuffer();
        listener.incoming(_socket, view);
      }
      catch (Exception x)
      {
        LOG.warn(x);
      }
    }
  }
}

代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-webapp

public void notifyIncoming(Buffer buffer, int read)
{
  if (listeners != null && !listeners.isEmpty() && read > 0)
  {
    for (NetworkTrafficListener listener : listeners)
    {
      try
      {
        Buffer view = buffer.asReadOnlyBuffer();
        listener.incoming(_socket, view);
      }
      catch (Exception x)
      {
        LOG.warn(x);
      }
    }
  }
}

代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-server

public void notifyIncoming(Buffer buffer, int read)
{
  if (listeners != null && !listeners.isEmpty() && read > 0)
  {
    for (NetworkTrafficListener listener : listeners)
    {
      try
      {
        Buffer view = buffer.asReadOnlyBuffer();
        listener.incoming(_socket, view);
      }
      catch (Exception x)
      {
        LOG.warn(x);
      }
    }
  }
}

代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-webapp

public void notifyOutgoing(Buffer buffer, int position, int written)
{
  if (listeners != null && !listeners.isEmpty() && written > 0)
  {
    for (NetworkTrafficListener listener : listeners)
    {
      try
      {
        Buffer view = buffer.asReadOnlyBuffer();
        view.setGetIndex(position);
        view.setPutIndex(position + written);
        listener.outgoing(_socket, view);
      }
      catch (Exception x)
      {
        LOG.warn(x);
      }
    }
  }
}

代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-all-server

public void notifyOutgoing(Buffer buffer, int position, int written)
{
  if (listeners != null && !listeners.isEmpty() && written > 0)
  {
    for (NetworkTrafficListener listener : listeners)
    {
      try
      {
        Buffer view = buffer.asReadOnlyBuffer();
        view.setGetIndex(position);
        view.setPutIndex(position + written);
        listener.outgoing(_socket, view);
      }
      catch (Exception x)
      {
        LOG.warn(x);
      }
    }
  }
}

代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-server

public void notifyOutgoing(Buffer buffer, int position, int written)
{
  if (listeners != null && !listeners.isEmpty() && written > 0)
  {
    for (NetworkTrafficListener listener : listeners)
    {
      try
      {
        Buffer view = buffer.asReadOnlyBuffer();
        view.setGetIndex(position);
        view.setPutIndex(position + written);
        listener.outgoing(_socket, view);
      }
      catch (Exception x)
      {
        LOG.warn(x);
      }
    }
  }
}

代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-plus

public void notifyOutgoing(Buffer buffer, int position, int written)
{
  if (listeners != null && !listeners.isEmpty() && written > 0)
  {
    for (NetworkTrafficListener listener : listeners)
    {
      try
      {
        Buffer view = buffer.asReadOnlyBuffer();
        view.setGetIndex(position);
        view.setPutIndex(position + written);
        listener.outgoing(_socket, view);
      }
      catch (Exception x)
      {
        LOG.warn(x);
      }
    }
  }
}

相关文章