Skip to content

Instantly share code, notes, and snippets.

@cablehead

cablehead/stream2.out

Last active February 29, 2024 20:31
Show Gist options
  • Save cablehead/1683dc284dfad9f54410ccc8d6797291 to your computer and use it in GitHub Desktop.
Save cablehead/1683dc284dfad9f54410ccc8d6797291 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
stream2.out
```
iter
and go
write: false
iter
write: Ok
want lock
have lock
process_value: []
iter
and go
write: false
write: Ok
want lock
have lock
process_value: [Record { val: Record { cols: ["id", "name", "data"], vals: [Nothing { internal_span: Span { start: 125573, end: 125625 } }, Nothing { internal_span: Span { start: 125573, end: 125625 } }, String { val: "{\"stamp\":\"03B9VNM8ETI3VSBYPOW5KJBVI\",\"ip\":\"38.147.250.103\",\"port\":62452,\"message\":\"more\"}\n", internal_span: Span { start: 125573, end: 125625 } }] }, internal_span: Span { start: 125573, end: 125625 } }]
iter
and go
write: false
want lock
have lock
write: Ok
╭────┬────┬──────┬───────────────────────────────────────────────────────────────────────────────────────────────────╮
│ # │ id │ name │ data │
├────┼────┼──────┼───────────────────────────────────────────────────────────────────────────────────────────────────┤
│ 0 │ │ │ {"stamp":"03AXE6ZGKGW8WGI3TKNEXPTMC","ip":"94.222.63.216","port":50498,"message":"Ohh │
│ │ │ │ noooooooooo, messages are permanent!!! I've said too much LoL"} │
│ │ │ │ │
│ 1 │ │ │ {"stamp":"03AXHZO0RTPZXJZ5P7U76AXMC","ip":"99.209.137.238","port":49816,"message":"Haha, just │
│ │ │ │ seeing that last post"} │
│ │ │ │ │
│ 2 │ │ │ {"stamp":"03AXHZR2CJX8T2ZHIXNYGJ46F","ip":"99.209.137.238","port":49816,"message":"as permanent │
│ │ │ │ as cat > messages.json, at least!"} │
│ │ │ │ │
│ 3 │ │ │ {"stamp":"03AXHZSQGR3YJVO3QZQQZM1BE","ip":"99.209.137.238","port":49816,"message":"now I want to │
│ │ │ │ edit messages"} │
│ │ │ │ │
│ 4 │ │ │ {"stamp":"03B6VS9DQJFQ0DPZ8Q58YSL0V","ip":"38.147.250.103","port":65439,"message":"hi"} │
│ │ │ │ │
│ 5 │ │ │ {"stamp":"03B9TVBJXW4ZD9HW8JV1TVE0H","ip":"38.147.250.103","port":65065,"message":"hai"} │
│ │ │ │ │
│ 6 │ │ │ {"stamp":"03B9UW2KI7VBEDZJ2YIVMP4UY","ip":"38.147.250.103","port":62422,"message":"go"} │
│ │ │ │ │
│ 7 │ │ │ {"stamp":"03B9UWEY6Y29M9TPPAYPDJRAO","ip":"38.147.250.103","port":62423,"message":"more"} │
│ │ │ │ │
│ 8 │ │ │ {"stamp":"03B9V0SVEQDQSYWXLTH8EKVLM","ip":"38.147.250.103","port":62429,"message":"more"} │
│ │ │ │ │
│ 9 │ │ │ {"stamp":"03B9VJ7ZADMHCW57VYECQGQEF","ip":"38.147.250.103","port":62445,"message":"more"} │
│ │ │ │ │
│ 10 │ │ │ {"stamp":"03B9VNM8ETI3VSBYPOW5KJBVI","ip":"38.147.250.103","port":62452,"message":"more"} │
│ │ │ │ │
╰────┴────┴──────┴───────────────────────────────────────────────────────────────────────────────────────────────────╯
```
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment