|
19 | 19 |
|
20 | 20 | from referencing import exceptions
|
21 | 21 | from referencing._attrs import frozen
|
22 |
| -from referencing.typing import URI, Anchor as AnchorType, D, Mapping |
| 22 | +from referencing.typing import URI, Anchor as AnchorType, D, Mapping, Retrieve |
23 | 23 |
|
24 | 24 | EMPTY_RESOURCES: PMap[URI, Resource[Any]] = pmap({}, pre_size=64)
|
25 | 25 | EMPTY_ANCHORS = cast(PMap[Tuple[URI, str], AnchorType[Any]], EMPTY_RESOURCES)
|
@@ -253,7 +253,7 @@ class Registry(Mapping[URI, Resource[D]]):
|
253 | 253 | default=EMPTY_ANCHORS,
|
254 | 254 | )
|
255 | 255 | _uncrawled: PSet[URI] = field(default=EMPTY_UNCRAWLED)
|
256 |
| - _retrieve: Callable[[URI], Resource[D]] = field(default=_fail_to_retrieve) |
| 256 | + _retrieve: Retrieve[D] = field(default=_fail_to_retrieve) |
257 | 257 |
|
258 | 258 | def __getitem__(self, uri: URI) -> Resource[D]:
|
259 | 259 | """
|
@@ -427,8 +427,8 @@ def combine(self, *registries: Registry[D]) -> Registry[D]:
|
427 | 427 | anchors = anchors.update(registry._anchors) # type: ignore[reportUnknownMemberType] # noqa: E501
|
428 | 428 | uncrawled = uncrawled.update(registry._uncrawled)
|
429 | 429 |
|
430 |
| - if registry._retrieve != _fail_to_retrieve: |
431 |
| - if registry._retrieve != retrieve != _fail_to_retrieve: |
| 430 | + if registry._retrieve is not _fail_to_retrieve: |
| 431 | + if registry._retrieve is not retrieve is not _fail_to_retrieve: |
432 | 432 | raise ValueError(
|
433 | 433 | "Cannot combine registries with conflicting retrieval "
|
434 | 434 | "functions.",
|
|
0 commit comments