File tree Expand file tree Collapse file tree 2 files changed +0
-28
lines changed Expand file tree Collapse file tree 2 files changed +0
-28
lines changed Original file line number Diff line number Diff line change @@ -23,13 +23,6 @@ use core::pipes;
23
23
use core:: prelude:: * ;
24
24
25
25
/// An extension of `pipes::stream` that allows both sending and receiving.
26
- #[ cfg( stage0) ]
27
- pub struct DuplexStream < T : Owned , U : Owned > {
28
- priv chan : Chan < T > ,
29
- priv port : Port < U > ,
30
- }
31
- #[ cfg( stage1) ]
32
- #[ cfg( stage2) ]
33
26
pub struct DuplexStream < T , U > {
34
27
priv chan : Chan < T > ,
35
28
priv port : Port < U > ,
Original file line number Diff line number Diff line change @@ -167,20 +167,6 @@ struct Database {
167
167
}
168
168
169
169
impl Database {
170
- #[ cfg( stage0) ]
171
- #[ cfg( stage1) ]
172
- fn prepare ( & mut self , fn_name : & str ,
173
- declared_inputs : & WorkMap ) -> Option < ( WorkMap , WorkMap , ~str ) >
174
- {
175
- let k = json_encode ( & ( fn_name, declared_inputs) ) ;
176
- let db_cache = copy self . db_cache ;
177
- match db_cache. find ( & k) {
178
- None => None ,
179
- Some ( & v) => Some ( json_decode ( copy v) )
180
- }
181
- }
182
-
183
- #[ cfg( stage2) ]
184
170
fn prepare ( & mut self , fn_name : & str ,
185
171
declared_inputs : & WorkMap ) -> Option < ( WorkMap , WorkMap , ~str ) >
186
172
{
@@ -235,13 +221,6 @@ struct Exec {
235
221
discovered_outputs: WorkMap
236
222
}
237
223
238
- #[cfg(stage0)]
239
- struct Work<T:Owned> {
240
- prep: @Mut<Prep>,
241
- res: Option<Either<T,PortOne<(Exec,T)>>>
242
- }
243
- #[cfg(stage1)]
244
- #[cfg(stage2)]
245
224
struct Work<T> {
246
225
prep: @Mut<Prep>,
247
226
res: Option<Either<T,PortOne<(Exec,T)>>>
You can’t perform that action at this time.
0 commit comments