We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1a833d2 commit b0d6688Copy full SHA for b0d6688
json-log-viewer/shared/src/main/scala/ru/d10xa/jsonlogviewer/LogViewerStream.scala
@@ -66,7 +66,16 @@ object LogViewerStream {
66
}
67
Stream.emits(feedStreams).parJoin(feedStreams.size)
68
} else {
69
- processStreamWithConfig(stdinLinesStream, resolvedConfigs.head)
+ val resolvedConfig = resolvedConfigs.head
70
+ val inputStream = if (resolvedConfig.inlineInput.isDefined) {
71
+ commandsAndInlineInputToStream(
72
+ resolvedConfig.commands,
73
+ resolvedConfig.inlineInput
74
+ )
75
+ } else {
76
+ stdinLinesStream
77
+ }
78
+ processStreamWithConfig(inputStream, resolvedConfig)
79
80
81
finalStream.intersperse("\n").append(Stream.emit("\n"))
0 commit comments