git.iko.soy/rowtype-yoga/purescript-kafkajs
on main help sign in
11 lines 373 B history raw
3exports.transactionImpl = (producer) => () => producer.transaction()
5exports.sendImpl = (transaction, data) => () => transaction.send(data)
7exports.sendOffsetsImpl = (transaction, sendOffsets) => () => transaction.sendOffsets(sendOffsets)
9exports.commitImpl = (transaction) => () => transaction.commit()
11exports.abortImpl = (transaction) => () => transaction.abort()