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

Frame.getStreamId介绍

[英]Return frame stream identifier
[中]返回帧流标识符

代码示例

代码示例来源：origin: rsocket/rsocket-java

private void handleIncomingFrames(Frame frame) {
 try {
  int streamId = frame.getStreamId();
  FrameType type = frame.getType();
  if (streamId == 0) {
   handleStreamZero(type, frame);
  } else {
   handleFrame(streamId, type, frame);
  }
 } finally {
  frame.release();
 }
}

代码示例来源：origin: rsocket/rsocket-java

public int getStreamIdForRequestType(FrameType expectedFrameType) {
  assertThat("Unexpected frames sent.", connection.getSent(), hasSize(greaterThanOrEqualTo(1)));
  List<FrameType> framesFound = new ArrayList<>();
  for (Frame frame : connection.getSent()) {
   if (frame.getType() == expectedFrameType) {
    return frame.getStreamId();
   }
   framesFound.add(frame.getType());
  }
  throw new AssertionError(
    "No frames sent with frame type: "
      + expectedFrameType
      + ", frames found: "
      + framesFound);
 }
}

代码示例来源：origin: rsocket/rsocket-java

private void handleFrame(Frame frame) {
 try {
  int streamId = frame.getStreamId();
  Subscriber<Payload> receiver;
  switch (frame.getType()) {

代码示例来源：origin: io.rsocket/rsocket-core

private void handleIncomingFrames(Frame frame) {
 try {
  int streamId = frame.getStreamId();
  FrameType type = frame.getType();
  if (streamId == 0) {
   handleStreamZero(type, frame);
  } else {
   handleFrame(streamId, type, frame);
  }
 } finally {
  frame.release();
 }
}

代码示例来源：origin: io.rsocket/rsocket-core

private void handleFrame(Frame frame) {
 try {
  int streamId = frame.getStreamId();
  Subscriber<Payload> receiver;
  switch (frame.getType()) {