discord-ext-rx 0.1.0

Combine RxPy with discord.py.

discord-ext-rx

Work In Progress!

Combine RxPy with discord.py.

Example

from discord.ext.rx import RxBot, _
from rx import operators as ops

bot = RxBot()

bot.messages.pipe(
    ops.filter(lambda m: m.author.id == 121678432504512512),
    ops.filter(lambda m: m.content == '418'),
    ops.map(lambda m: m.channel)
).subscribe(
    _(lambda c: c.send("I'm a teapot!"))
)

bot.run('token')