code: def _create_wallet_source(
      wallet: "Wallet", include_worth: bool = True
  ) -> "List[Stream[float]]":
      """Creates a list of streams to describe a `Wallet`.
  
      Parameters
      ----------
      wallet : `Wallet`
          The wallet to make streams for.
      include_worth : bool, default True
          Whether or
  
      Returns
      -------
      `List[Stream[float]]`
          A list of streams to describe the `wallet`.
      """
      exchange_name = wallet.exchange.name
      symbol = wallet.instrument.symbol
  
      streams = []
  
      with NameSpace(exchange_name + ":/" + symbol):
          free_balance = Stream.sensor(
              wallet, lambda w: w.balance.as_float(), dtype="float"
          ).rename("free")
          locked_balance = Stream.sensor(
              wallet,
              lambda w: w.locked_balance.as_float(),
              dtype="float",
          ).rename("locked")
          total_balance = Stream.sensor(
              wallet,
              lambda w: w.total_balance.as_float(),
              dtype="float",
          ).rename("total")
  
          streams += [free_balance, locked_balance, total_balance]
  
          if include_worth:
              price = Stream.select(
                  wallet.exchange.streams(),
                  lambda node: node.name.endswith(symbol),
              )
              worth = price.mul(total_balance).rename("worth")
              streams += [worth]
  
      return streams
  
imports: from typing import List
  import datetime
  import numpy
  import pandas
  from gym.spaces import Box, Space
  from random import randrange
  from tensortrade.feed.core import Stream, NameSpace, DataFeed
  from tensortrade.oms.wallets import Wallet
  from tensortrade.env.generic import Observer
  from collections import OrderedDict
label_desc: Use image node_id 1 for calling a global function with example usage: _create_wallet_source(wallet, include_worth) and returns: streams