SirEdvin

import aiochan as ac
import asyncio
import random

async def producer(c):
    i = 0
    while True:
        await asyncio.sleep(random.random()) # producing stuff takes time
        i += 1
        await c.put('product ' + str(i))

SirEdvin

Details:
        Mod File: BloodMagic-224791-3399440_mapped_official_1.16.5.jar
        Failure message: Blood Magic (bloodmagic) has failed to load correctly
                java.lang.ClassFormatError: Duplicate method name "getBlockPos" with signature "()Lnet.minecraft.util.math.BlockPos;" in class file wayoftime/bloodmagic/tile/TileMasterRitualStone
        Mod Version: 1.16.4-3.1.1-16
        Mod Issue URL: http://my.issue.tracker/
        Exception message: java.lang.ClassFormatError: Duplicate method name "getBlockPos" with signature "()Lnet.minecraft.util.math.BlockPos;" in class file wayoftime/bloodmagic/tile/TileMasterRitualStone
Stacktrace:
        at java.lang.ClassLoader.defineClass1(Native Method) ~[?:1.8.0_292] {}
        at java.lang.ClassLoader.defineClass(ClassLoader.java:756) ~[?:1.8.0_292] {}

SirEdvin

realityForger = peripheral.wrap("left")
playerDetector = peripheral.wrap("right")
chatBox = peripheral.wrap("back")

local gateBlocks = {
  {x=0, y=0, z=3},
  {x=1, y=0, z=3},
  {x=0, y=1, z=3},
  {x=1, y=1, z=3},
}

SirEdvin

data_dir = "/var/lib/vector"

# ------------------ SYSLOG message pipe ------------------ #

[sources.syslog_pipe_in]
    type = "socket"
    mode = "udp"
    address = "127.0.0.1:3333"

[transforms.syslog_pipe_parsing]

SirEdvin

51.83536124229431
28.677456378936768

SirEdvin

50.909597396850586
52.03043818473816

SirEdvin

[transforms.json_pipe_in]
    type = 'field_filter'
    inputs = ["syslog_pipe_out"]
    field = "target_format"
    value = "json"

[transforms.json_parser]
    type = "json_parser"
    inputs = ["json_pipe_in"]
    drop_invalid = true

SirEdvin

def test_base_propagation():
    class C1(funcsubs.SubscribableMixin):

        t1 = True
        t2 = True
        t3 = True

        def test1(self):
            TEST_HOOK.append(1)

SirEdvin

In [2]: from unqlite import UnQLite                                                                                                                  

In [3]: db = UnQLite()                                                                                                                               

In [4]: cdb = db.collection('test')                                                                                                                  

In [5]: cdb.create()                                                                                                                                 
 
In [6]: cdb.store({'c2': {}, 'c3': []})                                                                                                              
Out[6]: 0

SirEdvin

import os
import asyncio
import concurrent.futures
import random
import string

import zmq
import zmq.asyncio

ctx = zmq.asyncio.Context()