fiber = require('fiber')
box.cfg({listen = 3301})
box.schema.user.grant(
    'guest',
    'read,write,execute',
    'universe'
)
function server_function()
    x = {0,0}
    while x[1] < 3 do
        x[1] = x[1] + 1
        fiber.sleep(1)
        box.session.push(x)
    end
    fiber.sleep(1)
    return x
end

import tarantool


def callback(data, on_push_ctx=[]):
    print('run callback with data: ', data)
    data[0][1] = data[0][1] + 1
    on_push_ctx.append(data)


callback_res = []


conn = tarantool.connect(port=3301)
res = conn.call(
    'server_function',
    on_push=callback, 
    on_push_ctx=callback_res
)

# receiving out-of-band messages, 
# the conn.call is not finished yet.

>>> run callback with data:  [[1, 0]]
>>> run callback with data:  [[2, 0]]
>>> run callback with data:  [[3, 0]]

# the conn.call is finished now.


print(res)
>>> [3, 0]


print(callback_res)
>>>[[[1, 1]], [[2, 1]], [[3, 1]]]

box.schema.create_space(
 'tester', {
  format = {
    {name = 'id', type = 'unsigned'},
    {name = 'name', type = 'string'},
  }
})
box.space.tester:create_index(
 'primary_index', {
  parts = {
    {field = 1, type = 'unsigned'},
  }
})
function on_replace_callback()
    x = {0,0}
    while x[1] < 300 do
        x[1] = x[1] + 100
        box.session.push(x)
    end
    return x
end
box.space.tester:on_replace(
    on_replace_callback
)

callback_res = []


conn_pool = tarantool.ConnectionPool(
        [{'host':'localhost', 'port':3301}],
        user='guest')


res = conn_pool.insert(
    'tester',
    (1, 'Mike'),
    mode=tarantool.Mode.PREFER_RO,
    on_push=callback,
    on_push_ctx=callback_res,
)

# receiving out-of-band messages, 
# the conn_pool.insert is not finished yet.

>>> run callback with data:  [[100, 0]]
>>> run callback with data:  [[200, 0]]
>>> run callback with data:  [[300, 0]]

# the conn_pool.insert is finished now.


print(res)
>>> [1, 'Mike']


print(callback_res)
>>>[[[100, 1]], [[200, 1]], [[300, 1]]]