import asyncio
import i2plib
async def connect_test(destination):
    session_name = "test-connect"
    # create a SAM stream session
    await i2plib.create_session(session_name)
    # connect to a destination
    reader, writer = await i2plib.stream_connect(session_name, destination)
    # write data to a socket
    writer.write(b"PING")
    # asynchronously receive data
    data = await reader.read(4096)
    print(data.decode())
    # close the connection
    writer.close()
# run event loop
loop = asyncio.get_event_loop()
loop.run_until_complete(connect_test("dummy.i2p"))
loop.stop()

import asyncio
import i2plib
async def accept_test():
    session_name = "test-accept"
    # create a SAM stream session
    await i2plib.create_session(session_name)
    # accept a connection
    reader, writer = await i2plib.stream_accept(session_name)
    # first string on a client connection always contains clients I2P destination
    dest = await reader.readline()
    remote_destination = i2plib.Destination(dest.decode().strip())
    # read for the actual incoming data from the client
    data = await reader.read(4096)
    print(data.decode())
    # send data back
    writer.write(b"PONG")
    # close the connection
    writer.close()
# run event loop
loop = asyncio.get_event_loop()
loop.run_until_complete(accept_test())
loop.stop()

import asyncio
import i2plib
loop = asyncio.get_event_loop()
# making your local web server available in the I2P network
tunnel = i2plib.ServerTunnel(("127.0.0.1", 80))
asyncio.ensure_future(tunnel.run())
try:
    loop.run_forever()
except KeyboardInterrupt:
    pass
finally:
    loop.close()

import asyncio
import i2plib
loop = asyncio.get_event_loop()
# bind irc.echelon.i2p to 127.0.0.1:6669
tunnel = i2plib.ClientTunnel("irc.echelon.i2p", ("127.0.0.1", 6669))
asyncio.ensure_future(tunnel.run())
try:
    loop.run_forever()
except KeyboardInterrupt:
    pass
finally:
    loop.close()