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.IOExceptionpublic 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.IOExceptionpublic static void parseSseStream(java.io.InputStream inputStream,
org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber)
throws java.io.IOException
inputStream - 输入流subscriber - 订阅者java.io.IOException