Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(38)

Side by Side Diff: pkg/barback/lib/src/asset_forwarder.dart

Issue 261823008: Reorganize barback's source files. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: re-add barback/lib/src/internal_asset.dart Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « pkg/barback/lib/src/asset_cascade.dart ('k') | pkg/barback/lib/src/asset_id.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file.
4
5 library barback.asset_forwarder;
6
7 import 'dart:async';
8
9 import 'asset_node.dart';
10
11 /// A wrapper for an [AssetNode] that forwards events to a new node.
12 ///
13 /// A forwarder is used when a class wants to forward an [AssetNode] that it
14 /// gets as an input, but also wants to have control over when that node is
15 /// marked as removed. The forwarder can be closed, thus removing its output
16 /// node, without the original node having been removed.
17 class AssetForwarder {
18 /// The subscription on the input node.
19 StreamSubscription _subscription;
20
21 /// The controller for the output node.
22 final AssetNodeController _controller;
23
24 /// The node to which events are forwarded.
25 AssetNode get node => _controller.node;
26
27 AssetForwarder(AssetNode node)
28 : _controller = new AssetNodeController.from(node) {
29 if (node.state.isRemoved) return;
30
31 _subscription = node.onStateChange.listen((state) {
32 if (state.isAvailable) {
33 _controller.setAvailable(node.asset);
34 } else if (state.isDirty) {
35 _controller.setDirty();
36 } else {
37 assert(state.isRemoved);
38 close();
39 }
40 });
41 }
42
43 /// Closes the forwarder and marks [node] as removed.
44 void close() {
45 if (_controller.node.state.isRemoved) return;
46 _subscription.cancel();
47 _controller.setRemoved();
48 }
49 }
OLDNEW
« no previous file with comments | « pkg/barback/lib/src/asset_cascade.dart ('k') | pkg/barback/lib/src/asset_id.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698