Flutter: как сделать http-поток для StreamBuilder - PullRequest
Новая
       61

Flutter: как сделать http-поток для StreamBuilder

2 голосов
/ 17 июня 2020

Привет,

Я пытаюсь создать свое первое социальное приложение с Flutter, и я застрял. Я хотел бы получать свои сообщения (в разговоре между пользователями буксировки) с моего api. Это не проблема, когда я использую Future и Future Builder, но я бы хотел, чтобы список сообщений обновлялся при отправке нового сообщения!

Я обнаружил, что мы можем добиться этого с помощью потока, но каждый раз, когда я пытаюсь преобразовать свои Future In Stream, он все еще работает, но так же, как если бы это был Future (он никогда не обновлял новое сообщение).

здесь я упрощенная часть моего кода: 


class Test extends StatelessWidget {
  
  final Conv conv;
  final User otherUser;

  const Test({Key key, this.conv, this.otherUser}) : super(key: key);
  
  

  Stream<List<Message>> messageFlow(String convId) {
    return Stream.fromFuture(getMessages(convId));
  }

  Future<List<Message>> getMessages(String convId) async {
    var data = await http
        .post(MyApiUrl, headers: <String, String>{}, body: <String, String>{
      "someParam": "param",
      "id": convId,
    });
    var jsonData = json.decode(data.body);

    List<Message> messages = [];
    for (var m in jsonData) {
      Message message = Message.fromJson(m);
      messages.add(message);
    }
    return messages;
  }


  
  @override
  Widget build(BuildContext context) {
    return StreamBuilder(
        stream: messageFlow(conv.id),
        builder: (BuildContext context, AsyncSnapshot snapshot) {
          if (snapshot.data == null) {
            return Container(
              child: Center(
                child: Text('Loading'),
              ),
            );
          }
          return ListView.builder(
              reverse: true,
              controller: _messagesListController,
              itemCount: snapshot.data.length,
              itemBuilder: (BuildContext context, int index) {
                Message message = snapshot.data[index];
                var isMe = message.owner == otherUser.id ? false : true;
                return _buildMessage(message, isMe);
              });
        });
  }
}

it было бы так хорошо, если бы вы мне помогли!

...