Created
February 18, 2022 00:51
-
-
Save Desdaemon/be5da0a1c6b4724f20093ef434959744 to your computer and use it in GitHub Desktop.
Long-running StreamSink
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
use anyhow::Result; | |
use std::{thread::sleep, time::Duration}; | |
use flutter_rust_bridge::StreamSink; | |
const ONE_SECOND: Duration = Duration::from_secs(1); | |
// can't omit the return type yet, this is a bug | |
pub fn tick(sink: StreamSink<i32>) -> Result<()> { | |
let mut ticks = 0; | |
loop { | |
sink.add(ticks); | |
sleep(ONE_SECOND); | |
if ticks == i32::MAX { | |
break; | |
} | |
ticks += 1; | |
} | |
Ok(()) | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import 'package:flutter/material.dart'; | |
import 'ffi.dart'; | |
void main() { | |
runApp(const MyApp()); | |
} | |
class MyApp extends StatelessWidget { | |
const MyApp({Key? key}) : super(key: key); | |
@override | |
Widget build(BuildContext context) { | |
return MaterialApp( | |
title: 'Flutter Demo', | |
theme: ThemeData( | |
primarySwatch: Colors.blue, | |
), | |
home: const MyHomePage(title: 'Flutter Demo Home Page'), | |
); | |
} | |
} | |
class MyHomePage extends StatefulWidget { | |
const MyHomePage({Key? key, required this.title}) : super(key: key); | |
final String title; | |
@override | |
State<MyHomePage> createState() => _MyHomePageState(); | |
} | |
class _MyHomePageState extends State<MyHomePage> { | |
late Stream<int> ticks; | |
@override | |
void initState() { | |
super.initState(); | |
ticks = api.tick(); | |
} | |
@override | |
Widget build(BuildContext context) { | |
return Scaffold( | |
appBar: AppBar( | |
title: Text(widget.title), | |
), | |
body: Center( | |
child: Column( | |
mainAxisAlignment: MainAxisAlignment.center, | |
children: <Widget>[ | |
const Text("Time since starting Rust stream"), | |
StreamBuilder<int>( | |
stream: ticks, | |
builder: (context, snap) { | |
final style = Theme.of(context).textTheme.headline4; | |
final error = snap.error; | |
if (error != null) | |
return Tooltip( | |
message: error.toString(), | |
child: Text('Error', style: style)); | |
final data = snap.data; | |
if (data != null) return Text('$data second(s)', style: style); | |
return const CircularProgressIndicator(); | |
}, | |
) | |
], | |
), | |
), | |
); | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment