Skip to content

Instantly share code, notes, and snippets.

@cablehead

cablehead/stream.out

Created February 29, 2024 20:37
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save cablehead/99d6bbde04ae45875f9c7523da647217 to your computer and use it in GitHub Desktop.
Save cablehead/99d6bbde04ae45875f9c7523da647217 to your computer and use it in GitHub Desktop.
Download ZIP
stream-with-trace.out
Raw
stream.out
2024-02-29 08:33:48.441 PM [TRACE] nu_cli::repl: [crates/nu-cli/src/repl.rs:776] eval source: http get https://ndyg.cross.stream/projects/chat-app/messages | from sse
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5752] parsing block: LiteBlock { block: [LitePipeline { commands: [Command(None, LiteCommand { comments: [], parts: [Span { start: 125515, end: 125519 }, Span { start: 125520, end: 125523 }, Span { start: 125524, end: 125576 }] }), Command(Some(Span { start: 125578, end: 125579 }), LiteCommand { comments: [], parts: [Span { start: 125580, end: 125584 }, Span { start: 125585, end: 125588 }] })] }] }
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5586] parsing: pipeline element: command
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5065] parsing: expression
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1105] parsing: call
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1217] parsing: internal call
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:814] parsing: internal call (decl id: 297)
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: string
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2692] parsing: string
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5586] parsing: pipeline element: command
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5065] parsing: expression
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1105] parsing: call
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1217] parsing: internal call
2024-02-29 08:33:48.442 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:814] parsing: internal call (decl id: 456)
2024-02-29 08:33:48.924 PM [TRACE] nu_plugin::plugin: [crates/nu-plugin/src/plugin/mod.rs:62] Starting plugin: "/Users/andy/.s/sessions/03B982FI3LF406403X7R7HD9Z/nu_plugin_from_sse/target/debug/nu_plugin_from_sse", shell = None
2024-02-29 08:33:48.939 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Hello(ProtocolInfo { protocol: NuPlugin, version: "0.90.2", features: [] })
2024-02-29 08:33:48.940 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Call(0, Run(CallInfo { name: "from sse", call: EvaluatedCall { head: Span { start: 125580, end: 125588 }, positional: [], named: [] }, input: ExternalStream(ExternalStreamInfo { span: Span { start: 125524, end: 125576 }, stdout: Some(RawStreamInfo { id: 0, is_binary: false, known_size: None }), stderr: None, exit_code: None, trim_end_newline: false }), config: None }))
ready to write
want lock
have lock
2024-02-29 08:33:48.945 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Hello(ProtocolInfo { protocol: NuPlugin, version: "0.90.2", features: [] })
call: ExternalStream { stdout: Some(RawStream), stderr: None, exit_code: None, span: Span { start: 125524, end: 125576 }, metadata: None, trim_end_newline: false }
command_from_sse fin
result: Ok(ListStream(ListStream, None))
writer: ListStream(ListStreamInfo { id: 0 })
want lock
have lock
ready to write
2024-02-29 08:33:48.956 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: CallResponse(0, PipelineData(ListStream(ListStreamInfo { id: 0 })))
2024-02-29 08:33:48.956 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5752] parsing block: LiteBlock { block: [LitePipeline { commands: [Command(None, LiteCommand { comments: [], parts: [Span { start: 94397, end: 94399 }, Span { start: 94400, end: 94419 }, Span { start: 94420, end: 94422 }, Span { start: 94423, end: 94426 }, Span { start: 94427, end: 94439 }, Span { start: 94440, end: 94444 }, Span { start: 94445, end: 94454 }] })] }] }
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5258] parsing: builtin commands
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5294] parsing: checking for keywords
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5065] parsing: expression
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4842] parsing: math expression
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1105] parsing: call
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1217] parsing: internal call
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:814] parsing: internal call (decl id: 21)
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:652] parsing: math expression
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4842] parsing: math expression
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: any
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2066] parsing: full cell path
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2079] parsing: paren-head of full cell path
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5752] parsing block: LiteBlock { block: [LitePipeline { commands: [Command(None, LiteCommand { comments: [], parts: [Span { start: 94401, end: 94405 }, Span { start: 94406, end: 94410 }] })] }] }
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5258] parsing: builtin commands
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5262] parsing: not math expression or unaliasable parser keyword
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5294] parsing: checking for keywords
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5065] parsing: expression
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1105] parsing: call
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1217] parsing: internal call
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:814] parsing: internal call (decl id: 207)
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2692] parsing: string
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: any
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: binary
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: filesize
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: duration
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: range
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: datetime
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: int
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: block
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4084] parsing: block expression
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5752] parsing block: LiteBlock { block: [LitePipeline { commands: [Command(None, LiteCommand { comments: [], parts: [Span { start: 94429, end: 94434 }, Span { start: 94435, end: 94437 }] })] }] }
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5258] parsing: builtin commands
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5262] parsing: not math expression or unaliasable parser keyword
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5294] parsing: checking for keywords
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5065] parsing: expression
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.957 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1105] parsing: call
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1217] parsing: internal call
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:814] parsing: internal call (decl id: 244)
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:726] parsing: keyword(else) OneOf([Block, Expression])
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4506] parsing: value: block
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:4084] parsing: block expression
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5752] parsing block: LiteBlock { block: [LitePipeline { commands: [Command(None, LiteCommand { comments: [], parts: [Span { start: 94447, end: 94452 }] })] }] }
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5258] parsing: builtin commands
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5262] parsing: not math expression or unaliasable parser keyword
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5294] parsing: checking for keywords
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:5065] parsing: expression
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2303] parsing: filesize
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2284] parsing: duration
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:2229] parsing: datetime
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1255] parsing: binary
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1471] parsing: range
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1105] parsing: call
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:1217] parsing: internal call
2024-02-29 08:33:48.958 PM [TRACE] nu_parser::parser: [crates/nu-parser/src/parser.rs:814] parsing: internal call (decl id: 244)
iter
and go
write: false
2024-02-29 08:33:48.992 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 65, 88, 72, 90, 79, 48, 82, 84, 80, 90, 88, 74, 90, 53, 80, 55, 85, 55, 54, 65, 88, 77, 67, 34, 44, 34, 105, 112, 34, 58, 34, 57, 57, 46, 50, 48, 57, 46, 49, 51, 55, 46, 50, 51, 56, 34, 44, 34, 112, 111, 114, 116, 34, 58, 52, 57, 56, 49, 54, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 72, 97, 104, 97, 44, 32, 106, 117, 115, 116, 32, 115, 101, 101, 105, 110, 103, 32, 116, 104, 97, 116, 32, 108, 97, 115, 116, 32, 112, 111, 115, 116, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 65, 88, 72, 90, 82, 50, 67, 74, 88, 56, 84, 50, 90, 72, 73, 88, 78, 89, 71, 74, 52, 54, 70, 34, 44, 34, 105, 112, 34, 58, 34, 57, 57, 46, 50, 48, 57, 46, 49, 51, 55, 46, 50, 51, 56, 34, 44, 34, 112, 111, 114, 116, 34, 58, 52, 57, 56, 49, 54, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 97, 115, 32, 112, 101, 114, 109, 97, 110, 101, 110, 116, 32, 97, 115, 32, 99, 97, 116, 32, 62, 32, 109, 101, 115, 115, 97, 103, 101, 115, 46, 106, 115, 111, 110, 44, 32, 97, 116, 32, 108, 101, 97, 115, 116, 33, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 65, 88, 72, 90, 83, 81, 71, 82, 51, 89, 74, 86, 79, 51, 81, 90, 81, 81, 90, 77, 49, 66, 69, 34, 44, 34, 105, 112, 34, 58, 34, 57, 57, 46, 50, 48, 57, 46, 49, 51, 55, 46, 50, 51, 56, 34, 44, 34, 112, 111, 114, 116, 34, 58, 52, 57, 56, 49, 54, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 110, 111, 119, 32, 73, 32, 119, 97, 110, 116, 32, 116, 111, 32, 101, 100, 105, 116, 32, 109, 101, 115, 115, 97, 103, 101, 115, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 66, 54, 86, 83, 57, 68, 81, 74, 70, 81, 48, 68, 80, 90, 56, 81, 53, 56, 89, 83, 76, 48, 86, 34, 44, 34, 105, 112, 34, 58, 34, 51, 56, 46, 49, 52, 55, 46, 50, 53, 48, 46, 49, 48, 51, 34, 44, 34, 112, 111, 114, 116, 34, 58, 54, 53, 52, 51, 57, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 104, 105, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 66, 57, 84, 86, 66, 74, 88, 87, 52, 90, 68, 57, 72, 87, 56, 74, 86, 49, 84, 86, 69, 48, 72, 34, 44, 34, 105, 112, 34, 58, 34, 51, 56, 46, 49, 52, 55, 46, 50, 53, 48, 46, 49, 48, 51, 34, 44, 34, 112, 111, 114, 116, 34, 58, 54, 53, 48, 54, 53, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 104, 97, 105, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.993 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 66, 57, 85, 87, 50, 75, 73, 55, 86, 66, 69, 68, 90, 74, 50, 89, 73, 86, 77, 80, 52, 85, 89, 34, 44, 34, 105, 112, 34, 58, 34, 51, 56, 46, 49, 52, 55, 46, 50, 53, 48, 46, 49, 48, 51, 34, 44, 34, 112, 111, 114, 116, 34, 58, 54, 50, 52, 50, 50, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 103, 111, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 66, 57, 85, 87, 69, 89, 54, 89, 50, 57, 77, 57, 84, 80, 80, 65, 89, 80, 68, 74, 82, 65, 79, 34, 44, 34, 105, 112, 34, 58, 34, 51, 56, 46, 49, 52, 55, 46, 50, 53, 48, 46, 49, 48, 51, 34, 44, 34, 112, 111, 114, 116, 34, 58, 54, 50, 52, 50, 51, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 109, 111, 114, 101, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 66, 57, 86, 48, 83, 86, 69, 81, 68, 81, 83, 89, 87, 88, 76, 84, 72, 56, 69, 75, 86, 76, 77, 34, 44, 34, 105, 112, 34, 58, 34, 51, 56, 46, 49, 52, 55, 46, 50, 53, 48, 46, 49, 48, 51, 34, 44, 34, 112, 111, 114, 116, 34, 58, 54, 50, 52, 50, 57, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 109, 111, 114, 101, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 66, 57, 86, 74, 55, 90, 65, 68, 77, 72, 67, 87, 53, 55, 86, 89, 69, 67, 81, 71, 81, 69, 70, 34, 44, 34, 105, 112, 34, 58, 34, 51, 56, 46, 49, 52, 55, 46, 50, 53, 48, 46, 49, 48, 51, 34, 44, 34, 112, 111, 114, 116, 34, 58, 54, 50, 52, 52, 53, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 109, 111, 114, 101, 34, 125, 10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 66, 57, 86, 78, 77, 56, 69, 84, 73, 51, 86, 83, 66, 89, 80, 79, 87, 53, 75, 74, 66, 86, 73, 34, 44, 34, 105, 112, 34, 58, 34, 51, 56, 46, 49, 52, 55, 46, 50, 53, 48, 46, 49, 48, 51, 34, 44, 34, 112, 111, 114, 116, 34, 58, 54, 50, 52, 53, 50, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 109, 111, 114, 101, 34, 125, 10]))))
write: Ok
want lock
have lock
iter
and go
write: false
2024-02-29 08:33:48.994 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
process_value: []
want lock
have lock
process_value: [Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03AXHZO0RTPZXJZ5P7U76AXMC\",\"ip\":\"99.209.137.238\",\"port\":49816,\"message\":\"Haha, just seeing that last post\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
write: Ok
want lock
have lock
process_value: []
want lock
have lock
process_value: [Record { val: Record { cols2024-02-29 08:33:48.998 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
: ["id", "name", "data"], vals: 2024-02-29 08:33:48.998 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
[Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03AXHZR2CJX8T2ZHIXNYGJ46F\",\"ip\":\"99.209.137.238\",\"port\":49816,\"message\":\"as permanent as cat > messages.json, at least!\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
write: Ok
want lock
have lock
process_value: []
want lock
have lock
process_value: [Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03AXHZSQGR3YJVO3QZQQZM1BE\",\"ip\":\"99.209.137.238\",\"port\":49816,\"message\":\"now I want to edit messages\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03AXHZO0RTPZXJZ5P7U76AXMC\",\"ip\":\"99.209.137.238\",\"port\":49816,\"message\":\"Haha, just seeing that last post\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
write: Ok
want lock
have lock
process_value: []
want lock
have lock
process_value: [Record { val: Record { cols: [2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
"id", "name", "data"], vals: [Nothing { internal_span: Span { start: 2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
125524, end: 125576 } }, Nothing { internal_span: Span2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
{ start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B6VS9DQJFQ0DPZ8Q58YSL0V\",\"ip\":\"38.147.250.103\",\"port\":65439,\"message\":\"hi\"}\n", internal_span: Span { start: 125524, end: 1255762024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03AXHZR2CJX8T2ZHIXNYGJ46F\",\"ip\":\"99.209.137.238\",\"port\":49816,\"message\":\"as permanent as cat > messages.json, at least!\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
} }] }, internal_span: Span { start: 125524, end: 125576 } }2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
]
iter
and go
write: false
want lock
have lock
2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
write: Ok
want lock
have lock
2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
process_value: []
want lock
have lock
process_value: [Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03AXHZSQGR3YJVO3QZQQZM1BE\",\"ip\":\"99.209.137.238\",\"port\":49816,\"message\":\"now I want to edit messages\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
{ start: 125524, end: 125576 } }, String2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
{ val: "{\"stamp\":\"2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
03B9TVBJXW4ZD9HW8JV1TVE0H\",\"ip\":\"38.147.250.1032024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
\",\"port\":65065,\"message\":\"hai\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 }2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B6VS9DQJFQ0DPZ8Q58YSL0V\",\"ip\":\"38.147.250.103\",\"port\":65439,\"message\":\"hi\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
}]
iter
and go
write: false
want lock
have lock
2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
write: Ok
want lock
have lock
process_value: [2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs]:231] from plugin: Stream(Ack(0))
want lock
have lock
2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
process_value: [Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B9TVBJXW4ZD9HW8JV1TVE0H\",\"ip\":\"38.147.250.103\",\"port\":65065,\"message\":\"hai\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
stamp\":\"03B9UW2KI7VBEDZJ2YIVMP4UY\",\"ip\":2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
\"38.147.250.103\",\"port\":62422,\"message\":\"go\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
write: Ok
want lock
have lock
2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
process_value: []
want lock
have lock
2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
process_value: [Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, 2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B9UW2KI7VBEDZJ2YIVMP4UY\",\"ip\":\"38.147.250.103\",\"port\":62422,\"message\":\"go\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
String { val: "{\"stamp\":\"03B9UWEY6Y29M9TPPAYPDJRAO\",\2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
"ip\":\"38.147.250.103\",\"port\":62423,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
write: Ok
want lock
have lock
process_value: []
2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
want lock
have lock
process_value: [Record { val: 2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B9UWEY6Y29M9TPPAYPDJRAO\",\"ip\":\"38.147.250.103\",\"port\":62423,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
\"stamp\":\"03B9V0SVEQDQSYWXLTH8EKVLM\",\"2024-02-29 08:33:48.999 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
ip\":\"38.147.250.103\",\"port\":62429,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
write: Ok
want lock
have lock
process_value: []
2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
want lock
have lock
process_value: 2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
[Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, 2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B9V0SVEQDQSYWXLTH8EKVLM\",\"ip\":\"38.147.250.103\",\"port\":62429,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
String { val: "{\"stamp\":\"03B9VJ7ZADMHCW57VYECQGQEF\",\"ip\2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
":\"38.147.250.103\",\"port\":62445,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
write: Ok
want lock
have lock
process_value: []2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
want lock
have lock
process_value: 2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
[Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B9VJ7ZADMHCW57VYECQGQEF\",\"ip\":\"38.147.250.103\",\"port\":62445,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
125576 } }, String { val: "{\"stamp\":\"2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
03B9VNM8ETI3VSBYPOW5KJBVI\",\"ip\":\"38.147.250.103\",\"port\":62452,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
write: Ok
2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B9VNM8ETI3VSBYPOW5KJBVI\",\"ip\":\"38.147.250.103\",\"port\":62452,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
2024-02-29 08:33:49.000 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
BLOCK, and then TRIGGER NEW SSE MESSAGE
iter
and go
write: false
2024-02-29 08:35:13.031 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([100, 97, 116, 97, 58, 32, 123, 34, 115, 116, 97, 109, 112, 34, 58, 34, 48, 51, 66, 57, 86, 79, 74, 81, 87, 53, 75, 70, 77, 69, 77, 76, 85, 82, 80, 87, 74, 65, 75, 54, 57, 34, 44, 34, 105, 112, 34, 58, 34, 51, 56, 46, 49, 52, 55, 46, 50, 53, 48, 46, 49, 48, 51, 34, 44, 34, 112, 111, 114, 116, 34, 58, 54, 50, 52, 53, 53, 44, 34, 109, 101, 115, 115, 97, 103, 101, 34, 58, 34, 109, 111, 114, 101, 34, 125, 10]))))
write: Ok
want lock
have lock
process_value: []
2024-02-29 08:35:13.033 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
iter
and go
write: false
2024-02-29 08:35:13.072 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Data(0, Raw(Ok([10]))))
write: Ok
want lock
have lock
process_value: [Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B9VOJQW5KFMEMLURPWJAK69\",\"ip\":\"38.147.250.103\",\"port\":62455,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } }]
iter
and go
write: false
want lock
have lock
write: Ok
2024-02-29 08:35:13.073 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Ack(0))
2024-02-29 08:35:13.073 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:231] from plugin: Stream(Data(0, List(Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125524, end: 125576 } }, Nothing { internal_span: Span { start: 125524, end: 125576 } }, String { val: "{\"stamp\":\"03B9VOJQW5KFMEMLURPWJAK69\",\"ip\":\"38.147.250.103\",\"port\":62455,\"message\":\"more\"}\n", internal_span: Span { start: 125524, end: 125576 } }] }, internal_span: Span { start: 125524, end: 125576 } })))
2024-02-29 08:35:13.078 PM [TRACE] nu_plugin::plugin::interface::plugin: [crates/nu-plugin/src/plugin/interface/plugin.rs:466] to plugin: Stream(Ack(0))
╭────┬────┬──────┬─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮
│ # │ id │ name │ data │
├────┼────┼──────┼─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┤
│ 0 │ │ │ {"stamp":"03AXHZO0RTPZXJZ5P7U76AXMC","ip":"99.209.137.238","port":49816,"message":"Haha, just seeing that last post"} │
│ │ │ │ │
│ 1 │ │ │ {"stamp":"03AXHZR2CJX8T2ZHIXNYGJ46F","ip":"99.209.137.238","port":49816,"message":"as permanent as cat > messages.json, at least!"} │
│ │ │ │ │
│ 2 │ │ │ {"stamp":"03AXHZSQGR3YJVO3QZQQZM1BE","ip":"99.209.137.238","port":49816,"message":"now I want to edit messages"} │
│ │ │ │ │
│ 3 │ │ │ {"stamp":"03B6VS9DQJFQ0DPZ8Q58YSL0V","ip":"38.147.250.103","port":65439,"message":"hi"} │
│ │ │ │ │
│ 4 │ │ │ {"stamp":"03B9TVBJXW4ZD9HW8JV1TVE0H","ip":"38.147.250.103","port":65065,"message":"hai"} │
│ │ │ │ │
│ 5 │ │ │ {"stamp":"03B9UW2KI7VBEDZJ2YIVMP4UY","ip":"38.147.250.103","port":62422,"message":"go"} │
│ │ │ │ │
│ 6 │ │ │ {"stamp":"03B9UWEY6Y29M9TPPAYPDJRAO","ip":"38.147.250.103","port":62423,"message":"more"} │
│ │ │ │ │
│ 7 │ │ │ {"stamp":"03B9V0SVEQDQSYWXLTH8EKVLM","ip":"38.147.250.103","port":62429,"message":"more"} │
│ │ │ │ │
│ 8 │ │ │ {"stamp":"03B9VJ7ZADMHCW57VYECQGQEF","ip":"38.147.250.103","port":62445,"message":"more"} │
│ │ │ │ │
│ 9 │ │ │ {"stamp":"03B9VNM8ETI3VSBYPOW5KJBVI","ip":"38.147.250.103","port":62452,"message":"more"} │
│ │ │ │ │
│ 10 │ │ │ {"stamp":"03B9VOJQW5KFMEMLURPWJAK69","ip":"38.147.250.103","port":62455,"message":"more"} │
│ │ │ │ │
╰────┴────┴──────┴─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment