io.reactivex.netty.RxNetty.isUsingNativeTransport()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(4.9k)|赞(0)|评价(0)|浏览(52)

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

RxNetty.isUsingNativeTransport介绍

暂无

代码示例

代码示例来源:origin: ReactiveX/RxNetty

public static Class<? extends Channel> defaultSocketChannelClass() {
  return RxNetty.isUsingNativeTransport() ? EpollSocketChannel.class : NioSocketChannel.class;
}

代码示例来源:origin: ReactiveX/RxNetty

@Override
public EventLoopGroup globalClientEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeClientEventLoop();
  }
  return globalClientEventLoop();
}

代码示例来源:origin: ReactiveX/RxNetty

@Override
public EventLoopGroup globalServerParentEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeParentEventLoop();
  }
  return globalServerParentEventLoop();
}

代码示例来源:origin: ReactiveX/RxNetty

@Override
public EventLoopGroup globalServerEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeEventLoop();
  }
  return globalServerEventLoop();
}

代码示例来源:origin: io.reactivex/rxnetty

@Override
protected Class<? extends ServerChannel> defaultServerChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollServerSocketChannel.class;
  }
  return NioServerSocketChannel.class;
}

代码示例来源:origin: com.netflix.rxnetty/rx-netty

@Override
protected Class<? extends ServerChannel> defaultServerChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollServerSocketChannel.class;
  }
  return NioServerSocketChannel.class;
}

代码示例来源:origin: io.reactivex/rxnetty

@Override
protected Class<? extends SocketChannel> defaultSocketChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollSocketChannel.class;
  }
  return super.defaultSocketChannelClass();
}

代码示例来源:origin: io.reactivex/rxnetty

@Override
protected Class<? extends SocketChannel> defaultSocketChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollSocketChannel.class;
  }
  return super.defaultSocketChannelClass();
}

代码示例来源:origin: io.reactivex/rxnetty

@Override
protected Class<? extends SocketChannel> defaultSocketChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollSocketChannel.class;
  }
  return super.defaultSocketChannelClass();
}

代码示例来源:origin: com.netflix.rxnetty/rx-netty

@Override
protected Class<? extends SocketChannel> defaultSocketChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollSocketChannel.class;
  }
  return super.defaultSocketChannelClass();
}

代码示例来源:origin: io.reactivex/rxnetty

@Override
protected Class<? extends SocketChannel> defaultSocketChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollSocketChannel.class;
  }
  return super.defaultSocketChannelClass();
}

代码示例来源:origin: com.netflix.rxnetty/rx-netty

@Override
protected Class<? extends SocketChannel> defaultSocketChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollSocketChannel.class;
  }
  return super.defaultSocketChannelClass();
}

代码示例来源:origin: com.netflix.rxnetty/rx-netty

@Override
protected Class<? extends SocketChannel> defaultSocketChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollSocketChannel.class;
  }
  return super.defaultSocketChannelClass();
}

代码示例来源:origin: com.netflix.rxnetty/rx-netty

@Override
protected Class<? extends SocketChannel> defaultSocketChannelClass() {
  if (RxNetty.isUsingNativeTransport()) {
    return EpollSocketChannel.class;
  }
  return super.defaultSocketChannelClass();
}

代码示例来源:origin: com.netflix.rxnetty/rx-netty

@Override
public EventLoopGroup globalClientEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeEventLoop();
  }
  return globalClientEventLoop();
}

代码示例来源:origin: io.reactivex/rxnetty

@Override
public EventLoopGroup globalServerParentEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeParentEventLoop();
  }
  return globalServerParentEventLoop();
}

代码示例来源:origin: com.netflix.rxnetty/rx-netty

@Override
public EventLoopGroup globalServerEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeEventLoop();
  }
  return globalServerEventLoop();
}

代码示例来源:origin: io.reactivex/rxnetty

@Override
public EventLoopGroup globalClientEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeEventLoop();
  }
  return globalClientEventLoop();
}

代码示例来源:origin: io.reactivex/rxnetty

@Override
public EventLoopGroup globalServerEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeEventLoop();
  }
  return globalServerEventLoop();
}

代码示例来源:origin: com.netflix.rxnetty/rx-netty

@Override
public EventLoopGroup globalServerParentEventLoop(boolean nativeTransport) {
  if (nativeTransport && RxNetty.isUsingNativeTransport()) {
    return getNativeParentEventLoop();
  }
  return globalServerParentEventLoop();
}

相关文章