org.noear.solon.net.http.textstream

Class TextStreamUtil

java.lang.Object

org.noear.solon.net.http.textstream.TextStreamUtil

public class TextStreamUtil
extends Object

文本流解析工具

Since:

3.1

Author:

noear

Constructor Summary

Constructors

Constructor and Description
TextStreamUtil()

Method Summary

Modifier and Type	Method and Description
static void	parseEventStream(InputStream inputStream, org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber) Deprecated. 3.1 parseSseStream(InputStream, Charset, Subscriber)
static org.reactivestreams.Publisher<String>	parseLineStream(HttpResponse response) 解析文件行流
static void	parseLineStream(HttpResponse response, org.reactivestreams.Subscriber<? super String> subscriber) 解析文件行流
static org.reactivestreams.Publisher<String>	parseLineStream(InputStream inputStream) 解析文件行流
static void	parseLineStream(InputStream inputStream, Charset charset, org.reactivestreams.Subscriber<? super String> subscriber) 解析文件行流
static org.reactivestreams.Publisher<ServerSentEvent>	parseSseStream(HttpResponse response) 解析服务推送事件流
static void	parseSseStream(HttpResponse response, org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber) 解析服务推送事件流
static org.reactivestreams.Publisher<ServerSentEvent>	parseSseStream(InputStream inputStream) 解析服务推送事件流
static void	parseSseStream(InputStream inputStream, Charset charset, org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber) 解析服务推送事件流
static void	parseTextStream(InputStream inputStream, org.reactivestreams.Subscriber<? super String> subscriber) Deprecated. 3.1 parseLineStream(InputStream, Charset, Subscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TextStreamUtil

public TextStreamUtil()

Method Detail

parseTextStream

@Deprecated
public static void parseTextStream(InputStream inputStream,
                                               org.reactivestreams.Subscriber<? super String> subscriber)
                                        throws IOException

Deprecated. 3.1 parseLineStream(InputStream, Charset, Subscriber)

解析文件行流

Parameters:

inputStream - 输入流

subscriber - 订阅者

Throws:

IOException

parseLineStream

public static org.reactivestreams.Publisher<String> parseLineStream(InputStream inputStream)

解析文件行流

Parameters:

inputStream - 输入流

Returns:

发布者

parseLineStream

public static org.reactivestreams.Publisher<String> parseLineStream(HttpResponse response)

解析文件行流

Parameters:

response - 响应

Returns:

发布者

parseLineStream

public static void parseLineStream(HttpResponse response,
                                   org.reactivestreams.Subscriber<? super String> subscriber)

解析文件行流

Parameters:

response - 响应

parseLineStream

public static void parseLineStream(InputStream inputStream,
                                   Charset charset,
                                   org.reactivestreams.Subscriber<? super String> subscriber)

解析文件行流

Parameters:

inputStream - 输入流

subscriber - 订阅者

parseEventStream

@Deprecated
public static void parseEventStream(InputStream inputStream,
                                                org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber)
                                         throws IOException

Deprecated. 3.1 parseSseStream(InputStream, Charset, Subscriber)

解析服务推送事件流

Parameters:

inputStream - 输入流

subscriber - 订阅者

Throws:

IOException

parseSseStream

public static org.reactivestreams.Publisher<ServerSentEvent> parseSseStream(InputStream inputStream)

解析服务推送事件流

Parameters:

inputStream - 输入流

Returns:

发布者

parseSseStream

public static org.reactivestreams.Publisher<ServerSentEvent> parseSseStream(HttpResponse response)

解析服务推送事件流

Parameters:

response - 响应

Returns:

发布者

parseSseStream

public static void parseSseStream(HttpResponse response,
                                  org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber)

解析服务推送事件流

Parameters:

response - 响应

parseSseStream

public static void parseSseStream(InputStream inputStream,
                                  Charset charset,
                                  org.reactivestreams.Subscriber<? super ServerSentEvent> subscriber)

解析服务推送事件流

Parameters:

inputStream - 输入流

subscriber - 订阅者