Fix put item in StoreStream with _remove (#181)

[ko0hi]

修正後、以下のテストコードがパスすることを確認しました（修正前はok_deleteがTrueにならず assert task.done()でエラーとなります）。

import pybotters
import asyncio


async def watch_position(store):
    ok_insert, ok_delete = False, False
    with store.positions.watch() as stream:
        async for msg in stream:
            if msg.operation == "insert":
                ok_insert = True
            if msg.operation == "delete":
                ok_delete = True

            if ok_insert and ok_delete:
                break


async def main():
    async with pybotters.Client(
        {
              "bitflyer": [
                "XXX",
                "XXX"
            ]
        }, base_url="https://api.bitflyer.com"
    ) as client:
        store = pybotters.bitFlyerDataStore()

        await client.ws_connect(
            "wss://ws.lightstream.bitflyer.com/json-rpc",
            send_json=[
                {
                    "method": "subscribe",
                    "params": {"channel": "lightning_executions_FX_BTC_JPY"},
                    "id": 1,
                },
                {
                    "method": "subscribe",
                    "params": {"channel": "child_order_events"},
                    "id": 2,
                },
            ],
            hdlr_json=store.onmessage,
        )

        task = asyncio.create_task(watch_position(store))

        await asyncio.sleep(3)

        entry_resp = await client.post(
            "/v1/me/sendchildorder",
            data={
                "product_code": "FX_BTC_JPY",
                "side": "BUY",
                "size": "0.01",
                "child_order_type": "MARKET",
            },
        )
        entry_data = await entry_resp.json()

        await store.positions.wait()

        positions = store.positions.find()
        assert len(positions) == 1

        exit_resp = await client.post(
            "/v1/me/sendchildorder",
            data={
                "product_code": "FX_BTC_JPY",
                "side": "SELL",
                "size": "0.01",
                "child_order_type": "MARKET",
            },
        )

        await store.positions.wait()
        positions = store.positions.find()
        assert len(positions) == 0


        assert task.done()


if __name__ == "__main__":
    asyncio.run(main())

Close #181

[MtkN1]

PRありがとうごとうございます！
数日多忙なのでレビューはもう暫くお待ち下さい🙏

[MtkN1]

LGTM