public class TextStreamUtil
extends java.lang.Object
构造器和说明 |
---|
TextStreamUtil() |
限定符和类型 | 方法和说明 |
---|---|
static void |
parseEventStream(java.io.InputStream inputStream,
org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber)
|
static void |
parseLineStream(java.io.InputStream inputStream,
org.reactivestreams.Subscriber<? super java.lang.String> subscriber)
解析文件行流
|
static void |
parseSseStream(java.io.InputStream inputStream,
org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber)
解析服务推送事件流
|
static void |
parseTextStream(java.io.InputStream inputStream,
org.reactivestreams.Subscriber<? super java.lang.String> subscriber)
|
@Deprecated public static void parseTextStream(java.io.InputStream inputStream, org.reactivestreams.Subscriber<? super java.lang.String> subscriber) throws java.io.IOException
inputStream
- 输入流subscriber
- 订阅者java.io.IOException
public static void parseLineStream(java.io.InputStream inputStream, org.reactivestreams.Subscriber<? super java.lang.String> subscriber) throws java.io.IOException
inputStream
- 输入流subscriber
- 订阅者java.io.IOException
@Deprecated public static void parseEventStream(java.io.InputStream inputStream, org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber) throws java.io.IOException
inputStream
- 输入流subscriber
- 订阅者java.io.IOException
public static void parseSseStream(java.io.InputStream inputStream, org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber) throws java.io.IOException
inputStream
- 输入流subscriber
- 订阅者java.io.IOException